Transform KafakFuture <-> CompletableFuture

Scratch.java

    // See https://issues.apache.org/jira/browse/KAFKA-6987 for ongoing work on KafkaFuture implementation of CompletableFuture
    private <T> CompletableFuture<T> toCompletableFuture(final KafkaFuture<T> kafkaFuture) {
        final CompletableFuture<T> wrappingFuture = new CompletableFuture<>();
        kafkaFuture.whenComplete((value, throwable) -> {
            if (throwable != null) {
                wrappingFuture.completeExceptionally(throwable);
            } else {
                wrappingFuture.complete(value);
            }
        });
        return wrappingFuture;
    }


    private <T> KafkaFuture<T> toKafkaFuture(final CompletableFuture<T> completableFuture) {
        final KafkaFutureImpl<T> wrappingFuture = new KafkaFutureImpl<>();
        completableFuture.whenComplete((value, throwable) -> {
            if (throwable != null) {
                wrappingFuture.completeExceptionally(throwable);
            } else {
                wrappingFuture.complete(value);
            }
        });
        return wrappingFuture;
    }

call toCompletableFuture : org.apache.kafka.common.errors.TimeoutException: The AdminClient thread is not accepting new calls.