From: Kai Moritz <kai@juplo.de>
Date: Sun, 17 Jul 2022 15:55:05 +0000 (+0200)
Subject: WIP
X-Git-Tag: wip-outbound-channel-adapter~6
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=89326c083c9a206ef4450caea5c25da23ac5c587;p=demos%2Fkafka%2Fwordcount

WIP
---

diff --git a/src/main/resources/integration.xml b/src/main/resources/integration.xml
index fc161e4..9e6a5f1 100644
--- a/src/main/resources/integration.xml
+++ b/src/main/resources/integration.xml
@@ -8,10 +8,13 @@
 		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>