@Override
    public boolean complete(T newValue) {
        return completableFuture.kafkaComplete(newValue);
    }
@see KafkaFutureImpl#thenApply(BaseFunction)
@deprecated Since Kafka 3.0.
clients/src/main/java/org/apache/kafka/common/internals/KafkaFutureImpl.java