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

WIP
---

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 94dc1c8..e1d2e10 100644
--- a/src/main/java/de/juplo/kafka/wordcount/splitter/SplitterApplication.java
+++ b/src/main/java/de/juplo/kafka/wordcount/splitter/SplitterApplication.java
@@ -24,9 +24,9 @@ public class SplitterApplication
 
 
 	@Bean
-	SplitterApplicationProperties properties()
+	String outputTopic()
 	{
-		return properties;
+		return properties.getOutputTopic();
 	}
 
 	@InboundChannelAdapter(channel = "recordings")
diff --git a/src/main/resources/integration.xml b/src/main/resources/integration.xml
index c67cccf..4971132 100644
--- a/src/main/resources/integration.xml
+++ b/src/main/resources/integration.xml
@@ -14,7 +14,7 @@
       id="foo"
       channel="words"
       kafka-template="kafkaTemplate"
-      topic-expression="#properties.getOutputTopic()"
+      topic-expression="outputTopic"
       message-key-expression="headers['kafka_receivedMessageKey']" />
 
 </beans>