Deprecate ListenableFuture Callback Extensions

Author: garyrussell

spring-kafka/src/main/java/org/springframework/kafka/core/KafkaFailureCallback.java

@@ -16,6 +16,8 @@
 
 package org.springframework.kafka.core;
 
+import java.util.function.BiConsumer;
+
 import org.springframework.util.concurrent.FailureCallback;
 
 /**
@@ -27,8 +29,11 @@
  *
  * @author Gary Russell
  * @since 2.5
+ * @deprecated as of 2.9.1, in favor of
+ * {@link java.util.concurrent.CompletableFuture#whenComplete(BiConsumer)}
  *
  */
+@Deprecated
 @FunctionalInterface
 public interface KafkaFailureCallback<K, V> extends FailureCallback {
 

spring-kafka/src/main/java/org/springframework/kafka/core/KafkaSendCallback.java

@@ -16,6 +16,8 @@
 
 package org.springframework.kafka.core;
 
+import java.util.function.BiConsumer;
+
 import org.springframework.kafka.support.SendResult;
 import org.springframework.util.concurrent.ListenableFutureCallback;
 
@@ -28,8 +30,11 @@
  *
  * @author Gary Russell
  * @since 2.5
+ * @deprecated as of 2.9.1, in favor of
+ * {@link java.util.concurrent.CompletableFuture#whenComplete(BiConsumer)}
  *
  */
+@Deprecated
 public interface KafkaSendCallback<K, V> extends ListenableFutureCallback<SendResult<K, V>>, KafkaFailureCallback<K, V> {
 
 }