Pull request: PR#4033
KafkaFuture.BiCosumer are currently public abstract classes with only one abstract method.
In a future release the
thenApply function which uses this class can be marked as
@Deprecated. Later on they can be removed.
When KIP-118 is implemented,
KafkaFuture can extend
CompletableFuture or implement
- Keep the current interface as is, as a nicer syntax to address this api might not be worth breaking backwards compatibility
- Wait for a kafka release which will not support java 7 anymore. And replace or extend
KafkaFuturewith the java 8
CompletionStage. This KIP can then become part of KIP-118: Drop Support for Java 7 in Kafka 0.11