From dcb10c48a59ab3e880de920edbab15f3cd0f1552 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Mon, 18 Jul 2022 21:30:50 +0200 Subject: [PATCH] WIP --- .../de/juplo/kafka/wordcount/splitter/SplitterApplication.java | 2 -- 1 file changed, 2 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 ea1fb17..8bd928b 100644 --- a/src/main/java/de/juplo/kafka/wordcount/splitter/SplitterApplication.java +++ b/src/main/java/de/juplo/kafka/wordcount/splitter/SplitterApplication.java @@ -17,14 +17,12 @@ import org.springframework.integration.kafka.outbound.KafkaProducerMessageHandle import org.springframework.integration.transformer.HeaderEnricher; import org.springframework.integration.transformer.support.ExpressionEvaluatingHeaderValueMessageProcessor; import org.springframework.integration.transformer.support.HeaderValueMessageProcessor; -import org.springframework.integration.transformer.support.StaticHeaderValueMessageProcessor; import org.springframework.kafka.core.ConsumerFactory; import org.springframework.kafka.core.KafkaTemplate; import org.springframework.kafka.listener.ContainerProperties; import org.springframework.kafka.listener.KafkaMessageListenerContainer; import org.springframework.messaging.MessageHandler; -import java.util.Collections; import java.util.HashMap; import java.util.Map; -- 2.20.1