@Override
    public CompletionStage<T> toCompletionStage() {
        return completableFuture;
    }
A flexible future which supports call chaining and other asynchronous programming patterns.
clients/src/main/java/org/apache/kafka/common/internals/KafkaFutureImpl.java