From: Kai Moritz <kai@juplo.de>
Date: Thu, 30 Jun 2022 19:25:22 +0000 (+0200)
Subject: WIP
X-Git-Tag: wip-integration-xml~2
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=b1b65a7a0c7b50b58903fb9563d239eb1d03ff0a;p=demos%2Fkafka%2Fwordcount

WIP
---

diff --git a/src/main/resources/integration.xml b/src/main/resources/integration.xml
index f6ec728..4ecea8b 100644
--- a/src/main/resources/integration.xml
+++ b/src/main/resources/integration.xml
@@ -8,6 +8,11 @@
 		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="source" consumer-factory="consumerFactory" channel="recordings"/>
+  <int-kafka:inbound-channel-adapter
+      id="recordings"
+      consumer-factory="kafkaConsumerFactory"
+      payload-type="java.lang.String"
+      group-id="splitter"
+      channel="recordings" />
 
 </beans>