From: Kai Moritz Date: Mon, 18 Jul 2022 19:21:24 +0000 (+0200) Subject: WIP:splitter: 1.0.0-spring-ingetration - message-driven channel-adapter X-Git-Tag: wip-header-enricher~3 X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=b960d40da52865206ec21fab0041169194d44b3e;p=demos%2Fkafka%2Fwordcount 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 --- 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(