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 7663ef9e7f..f323624554 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
@@ -534,8 +534,7 @@ public class KafkaProducerMessageHandler<K, V> extends AbstractReplyProducingMes
 		return processReplyFuture(gatewayFuture);
 	}
 
-	private void sendFutureIfRequested(final Message<?> message, ListenableFuture<SendResult<K, V>> sendFuture,
-			Object futureToken) {
+	private void sendFutureIfRequested(ListenableFuture<SendResult<K, V>> sendFuture, Object futureToken) {
 
 		if (futureToken != null) {
 			MessageChannel futures = getFuturesChannel();
diff --git a/src/reference/asciidoc/kafka.adoc b/src/reference/asciidoc/kafka.adoc
index 2cc87f8f42..7b3de1cb44 100644
--- a/src/reference/asciidoc/kafka.adoc
+++ b/src/reference/asciidoc/kafka.adoc
@@ -874,7 +874,8 @@ public class FuturesChannelApplication {
 
     @Bean
     IntegrationFlow inbound(ConsumerFactory<String, String> consumerFactory, Handler handler) {
-        return IntegrationFlows.from(Kafka.messageDrivenChannelAdapter(consumerFactory, ListenerMode.batch, "inTopic"))
+        return IntegrationFlows.from(Kafka.messageDrivenChannelAdapter(consumerFactory,
+                    ListenerMode.batch, "inTopic"))
                 .handle(handler)
                 .get();
     }