conduktor.io ↗

KIP-707 — The future of KafkaFuture

Accepted Kafka 3.0 AdminClient

Adds `KafkaFuture.toCompletionStage()` to allow conversion of `KafkaFuture` instances to Java's standard `CompletionStage`/`CompletableFuture` for interoperability with JDK async APIs and third-party libraries. `KafkaFuture` was designed when Java lacked `CompletionStage`; now that Java 8+ `CompletionStage` is universal, users must awkwardly wrap or unwrap `KafkaFuture` when composing async admin client operations.

Details

AuthorTom Bentley
StatusAccepted
Kafka Version3.0
JIRAKAFKA-6987
WikiView on Apache Wiki
Created2021-01-22
Last Modified2021-04-30
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.