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 (file)
--- 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(