From d7b83a099d973f11b37371bc3ac9b0fd13642825 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Sun, 17 Jul 2022 18:25:29 +0200 Subject: [PATCH] WIP --- .../kafka/wordcount/splitter/SplitterApplication.java | 11 ----------- 1 file changed, 11 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 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 source( -- 2.20.1