From 373e8e7cf3f64a319517d9bab2cc14b9d6bf101f Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Wed, 25 Sep 2024 13:56:29 +0200 Subject: [PATCH] Einheitliche Benennung des Producers -- ALIGN --- pom.xml | 2 +- src/main/java/de/juplo/kafka/ExampleProducer.java | 8 ++++---- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/pom.xml b/pom.xml index 2928676..02e80d3 100644 --- a/pom.xml +++ b/pom.xml @@ -61,7 +61,7 @@ true libs/ - de.juplo.kafka.SimpleProducer + de.juplo.kafka.ExampleProducer diff --git a/src/main/java/de/juplo/kafka/ExampleProducer.java b/src/main/java/de/juplo/kafka/ExampleProducer.java index db554d7..51178f5 100644 --- a/src/main/java/de/juplo/kafka/ExampleProducer.java +++ b/src/main/java/de/juplo/kafka/ExampleProducer.java @@ -10,7 +10,7 @@ import java.util.Properties; @Slf4j -public class SimpleProducer +public class ExampleProducer { private final String id; private final String topic; @@ -20,7 +20,7 @@ public class SimpleProducer private volatile boolean running = true; private volatile boolean done = false; - public SimpleProducer(String broker, String topic, String clientId) + public ExampleProducer(String broker, String topic, String clientId) { Properties props = new Properties(); props.put("bootstrap.servers", broker); @@ -124,7 +124,7 @@ public class SimpleProducer broker = args[0]; } - SimpleProducer instance = new SimpleProducer(broker, topic, clientId); + ExampleProducer instance = new ExampleProducer(broker, topic, clientId); Runtime.getRuntime().addShutdownHook(new Thread(() -> { @@ -142,7 +142,7 @@ public class SimpleProducer })); log.info( - "Running SimpleProducer: broker={}, topic={}, client-id={}", + "Running ExampleProducer: broker={}, topic={}, client-id={}", broker, topic, clientId); -- 2.20.1