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 e3b58f26010105825e74545cbd7f2c2b265d25ed..750fbeb49f467f40d1a21825e14e659de5b263f9 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(