From acb710f838684b4cdd53f58ceb9b9a8e479e765d Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Sun, 17 Jul 2022 18:11:40 +0200 Subject: [PATCH] WIP --- .../juplo/kafka/wordcount/splitter/SplitterApplication.java | 4 ++-- src/main/resources/integration.xml | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) 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 94dc1c8..e1d2e10 100644 --- 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 c67cccf..4971132 100644 --- 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']" /> -- 2.20.1