Fix previous commit

2020-10-19 11:48:18 -04:00
parent b6d60bfd69
commit 3cf66cc539
1 changed files with 1 additions and 1 deletions
--- 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();
 		}