http://www.springframework.org/schema/integration https://www.springframework.org/schema/integration/spring-integration.xsd
http://www.springframework.org/schema/integration/kafka http://www.springframework.org/schema/integration/kafka/spring-integration-kafka.xsd">
+ <int:channel id="words" />
+
<int-kafka:outbound-channel-adapter
- id="words"
+ id="foo"
+ channel="words"
kafka-template="kafkaTemplate"
- topic-expression="${juplo.wordcount.splitter.output-topic}"
+ topic-expression="'out'"
message-key-expression="headers['kafka_receivedMessageKey']" />
</beans>