From 4dac4a5ac82715b54d153fc9d97b07cc2dbd3d02 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Thu, 30 Jun 2022 21:37:01 +0200
Subject: [PATCH] WIP

---
 .../kafka/wordcount/splitter/SplitterApplication.java |  8 --------
 src/main/resources/integration.xml                    | 11 +++++------
 2 files changed, 5 insertions(+), 14 deletions(-)

diff --git a/src/main/java/de/juplo/kafka/wordcount/splitter/SplitterApplication.java b/src/main/java/de/juplo/kafka/wordcount/splitter/SplitterApplication.java
index e73d2bb..37ea9a7 100644
--- a/src/main/java/de/juplo/kafka/wordcount/splitter/SplitterApplication.java
+++ b/src/main/java/de/juplo/kafka/wordcount/splitter/SplitterApplication.java
@@ -30,14 +30,6 @@ import org.springframework.messaging.support.ChannelInterceptor;
 @ImportResource("classpath:integration.xml")
 public class SplitterApplication
 {
-	@Bean
-	MessageChannel words(ChannelInterceptor keyInterceptor)
-	{
-		DirectChannel words = new DirectChannel();
-		words.addInterceptor(keyInterceptor);
-		return words;
-	}
-
 	@Bean
 	ChannelInterceptor keyInterceptor ()
 	{
diff --git a/src/main/resources/integration.xml b/src/main/resources/integration.xml
index 4ecea8b..14bd157 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:channel id="words">
+    <int:interceptors>
+      <ref bean="keyInterceptor"/>
+    </int:interceptors>
+  </int:channel>
 
 </beans>
-- 
2.20.1