public <T> List<CompletableFuture<T>> scheduleReadAllOperation(
        String name,
        CoordinatorReadOperation<S, T> op
    ) {
        throwIfNotRunning();
        log.debug("Scheduled execution of read all operation {}.", name);
        return coordinators
            .keySet()
            .stream()
            .map(tp -> scheduleReadOperation(name, tp, op))
            .collect(Collectors.toList());
    }
Schedules a read operation for each coordinator.

@param name  The name of the read operation.
@param op    The read operation.

@return A list of futures where each future will be completed with the result of the read operation
when the operation is completed or an exception if the read operation failed.

@param <T> The type of the result.
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/runtime/CoordinatorRuntime.java