From: Kai Moritz <kai@juplo.de>
Date: Sun, 17 Jul 2022 16:25:29 +0000 (+0200)
Subject: WIP
X-Git-Tag: wip-outbound-channel-adapter~1
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=d7b83a099d973f11b37371bc3ac9b0fd13642825;p=demos%2Fkafka%2Fwordcount

WIP
---

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 e1d2e10..22576a0 100644
--- a/src/main/java/de/juplo/kafka/wordcount/splitter/SplitterApplication.java
+++ b/src/main/java/de/juplo/kafka/wordcount/splitter/SplitterApplication.java
@@ -1,6 +1,5 @@
 package de.juplo.kafka.wordcount.splitter;
 
-import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.boot.context.properties.EnableConfigurationProperties;
@@ -19,16 +18,6 @@ import org.springframework.kafka.listener.ConsumerProperties;
 @ImportResource("classpath:integration.xml")
 public class SplitterApplication
 {
-	@Autowired
-	SplitterApplicationProperties properties;
-
-
-	@Bean
-	String outputTopic()
-	{
-		return properties.getOutputTopic();
-	}
-
 	@InboundChannelAdapter(channel = "recordings")
 	@Bean
 	KafkaMessageSource<String, String> source(