@Override
    public boolean cancel(boolean mayInterruptIfRunning) {
        return completableFuture.cancel(mayInterruptIfRunning);
    }
If not already completed, completes this future with a CancellationException.  Dependent
futures that have not already completed will also complete exceptionally, with a
CompletionException caused by this CancellationException.
clients/src/main/java/org/apache/kafka/common/internals/KafkaFutureImpl.java