private static <T> void completeAllExceptionally(Stream<KafkaFutureImpl<T>> futures, Throwable exc) {
        futures.forEach(future -> future.completeExceptionally(exc));
    }
Send an exception to all futures in the provided stream

@param futures   The stream of KafkaFutureImpl objects.
@param exc       The exception
@param <T>       The KafkaFutureImpl result type.
clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java