WIP:splitter: 1.0.0-spring-ingetration - message-driven channel-adapter

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 e3b58f2..750fbeb 100644 (file)
--- a/src/main/java/de/juplo/kafka/wordcount/splitter/SplitterApplication.java
+++ b/src/main/java/de/juplo/kafka/wordcount/splitter/SplitterApplication.java
@@ -68,6 +68,7 @@ public class SplitterApplication
                                                consumerFactory,
                                                new ContainerProperties(properties.getInputTopic()));
        }
+
        @Bean
        @ServiceActivator(inputChannel = "words")
        MessageHandler handler(