diff --git a/src/reference/asciidoc/kafka.adoc b/src/reference/asciidoc/kafka.adoc index a34de03825..757773da4f 100644 --- a/src/reference/asciidoc/kafka.adoc +++ b/src/reference/asciidoc/kafka.adoc @@ -560,7 +560,7 @@ public IntegrationFlow serverGateway( ConcurrentMessageListenerContainer container, KafkaTemplate replyTemplate) { return IntegrationFlows - .from(Kafka.inboundGateway(container, template) + .from(Kafka.inboundGateway(container, replyTemplate) .replyTimeout(30_000)) .transform(String::toUpperCase) .get();