Hi everyone, I have a use case, where a KafkaCompletableFuture would be useful.
As far as I can tell KafkaFuture only implements Future < public abstract class KafkaFuture<T> implements Future<T> > [1] I found this KIP suggesting the change to CompletableFuture < When KIP-118<https://cwiki.apache.org/confluence/display/KAFKA/KIP-118%3A+Drop+Support+for+Java+7> is implemented, KafkaFuture can extend CompletableFuture or implement CompletionStage. > [2] KIP-218 is resolved in 1.1.0 [3] KIP-118 is resolved in 2.0.0 [4] Is the change to CompletableFuture still planned ? Is there a KIP or a JIRA ticket to keep track on this ongoing task ? (I didn't found one) Regards, Benoit 1 : https://github.com/apache/kafka/blob/3cdc78e6bb1f83973a14ce1550fe3874f7348b05/clients/src/main/java/org/apache/kafka/common/KafkaFuture.java 2 : https://cwiki.apache.org/confluence/display/KAFKA/KIP-218%3A+Make+KafkaFuture.Function+java+8+lambda+compatible 3 : https://issues.apache.org/jira/browse/KAFKA-6018 4 : https://issues.apache.org/jira/browse/KAFKA-4423
