Skip to content

Commit 71a273e

Browse files
authored
Fix naming in Inbound Kafka Gateway code sample
1 parent 8e7785d commit 71a273e

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/reference/asciidoc/kafka.adoc

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -560,7 +560,7 @@ public IntegrationFlow serverGateway(
560560
ConcurrentMessageListenerContainer<Integer, String> container,
561561
KafkaTemplate<Integer, String> replyTemplate) {
562562
return IntegrationFlows
563-
.from(Kafka.inboundGateway(container, template)
563+
.from(Kafka.inboundGateway(container, replyTemplate)
564564
.replyTimeout(30_000))
565565
.<String, String>transform(String::toUpperCase)
566566
.get();

0 commit comments

Comments
 (0)