public <T> List<CompletableFuture<T>> scheduleWriteAllOperation(
        String name,
        Duration timeout,
        CoordinatorWriteOperation<S, T, U> op
    ) {
        throwIfNotRunning();
        log.debug("Scheduled execution of write all operation {}.", name);
        return coordinators
            .keySet()
            .stream()
            .map(tp -> scheduleWriteOperation(name, tp, timeout, op))
            .collect(Collectors.toList());
    }
Schedule a write operation for each coordinator.

@param name      The name of the write operation.
@param timeout   The write operation timeout.
@param op        The write operation.

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

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