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 94dc1c8e5391b6ff8a63117f8d532c75d04d4a99..e1d2e1065c08d38b1747d6a8ca0f89d13b49ee48 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 c67cccfa720a80b276164b1f6d0f00d379b79467..4971132088bf11cec44e6a26cd6bb1f63fe72515 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>