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 (file)
--- 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 (file)
--- 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>