From b960d40da52865206ec21fab0041169194d44b3e Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Mon, 18 Jul 2022 21:21:24 +0200 Subject: [PATCH] WIP:splitter: 1.0.0-spring-ingetration - message-driven channel-adapter --- .../de/juplo/kafka/wordcount/splitter/SplitterApplication.java | 1 + 1 file changed, 1 insertion(+) 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( -- 2.20.1