diff --git a/spring-integration-kafka/src/main/java/org/springframework/integration/kafka/outbound/KafkaProducerMessageHandler.java b/spring-integration-kafka/src/main/java/org/springframework/integration/kafka/outbound/KafkaProducerMessageHandler.java
index f323624554..cb9aef46f1 100644
--- a/spring-integration-kafka/src/main/java/org/springframework/integration/kafka/outbound/KafkaProducerMessageHandler.java
+++ b/spring-integration-kafka/src/main/java/org/springframework/integration/kafka/outbound/KafkaProducerMessageHandler.java
@@ -517,7 +517,7 @@ public class KafkaProducerMessageHandler<K, V> extends AbstractReplyProducingMes
 				sendFuture = this.kafkaTemplate.send(producerRecord);
 			}
 		}
-		sendFutureIfRequested(message, sendFuture, futureToken);
+		sendFutureIfRequested(sendFuture, futureToken);
 		if (flush) {
 			this.kafkaTemplate.flush();
 		}