From 77cbd2b55e26b39be90a722761ebb6e59e8f965a Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Mon, 15 Aug 2022 20:40:16 +0200 Subject: [PATCH] =?utf8?q?Benennung=20vereinheitlicht=20und=20projektunabh?= =?utf8?q?=C3=A4ngig=20gemacht?= MIME-Version: 1.0 Content-Type: text/plain; charset=utf8 Content-Transfer-Encoding: 8bit --- .../java/de/juplo/kafka/ApplicationConfiguration.java | 8 ++++---- ...UpRecordHandler.java => ApplicationRecordHandler.java} | 2 +- 2 files changed, 5 insertions(+), 5 deletions(-) rename src/main/java/de/juplo/kafka/{SumUpRecordHandler.java => ApplicationRecordHandler.java} (96%) diff --git a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java index 753422e..60f45a9 100644 --- a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java +++ b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java @@ -19,11 +19,11 @@ import java.util.concurrent.Executors; public class ApplicationConfiguration { @Bean - public SumUpRecordHandler sumUpRecordHandler( + public ApplicationRecordHandler recordHandler( KafkaProducer kafkaProducer, ApplicationProperties properties) { - return new SumUpRecordHandler( + return new ApplicationRecordHandler( kafkaProducer, properties.getClientId(), properties.getTopicOut()); @@ -33,7 +33,7 @@ public class ApplicationConfiguration public EndlessConsumer endlessConsumer( KafkaConsumer kafkaConsumer, ExecutorService executor, - SumUpRecordHandler sumUpRecordHandler, + ApplicationRecordHandler recordHandler, ApplicationProperties properties) { return @@ -42,7 +42,7 @@ public class ApplicationConfiguration properties.getClientId(), properties.getTopicIn(), kafkaConsumer, - sumUpRecordHandler); + recordHandler); } @Bean diff --git a/src/main/java/de/juplo/kafka/SumUpRecordHandler.java b/src/main/java/de/juplo/kafka/ApplicationRecordHandler.java similarity index 96% rename from src/main/java/de/juplo/kafka/SumUpRecordHandler.java rename to src/main/java/de/juplo/kafka/ApplicationRecordHandler.java index 5d15b3b..a4b6a8f 100644 --- a/src/main/java/de/juplo/kafka/SumUpRecordHandler.java +++ b/src/main/java/de/juplo/kafka/ApplicationRecordHandler.java @@ -9,7 +9,7 @@ import org.apache.kafka.clients.producer.ProducerRecord; @RequiredArgsConstructor @Slf4j -public class SumUpRecordHandler implements RecordHandler +public class ApplicationRecordHandler implements RecordHandler { private final Producer producer; private final String id; -- 2.20.1