From faa427a187e8d875d9a6676f2dc04b71e6f4694c Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Sun, 17 Jul 2022 17:42:42 +0200
Subject: [PATCH] WIP
---
src/main/resources/integration.xml | 11 +++++------
1 file changed, 5 insertions(+), 6 deletions(-)
diff --git a/src/main/resources/integration.xml b/src/main/resources/integration.xml
index 4ecea8b..fc161e4 100644
--- a/src/main/resources/integration.xml
+++ b/src/main/resources/integration.xml
@@ -8,11 +8,10 @@
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-kafka:inbound-channel-adapter
- id="recordings"
- consumer-factory="kafkaConsumerFactory"
- payload-type="java.lang.String"
- group-id="splitter"
- channel="recordings" />
+ <int-kafka:outbound-channel-adapter
+ id="words"
+ kafka-template="kafkaTemplate"
+ topic-expression="${juplo.wordcount.splitter.output-topic}"
+ message-key-expression="headers['kafka_receivedMessageKey']" />
</beans>
--
2.20.1