From: Kai Moritz Date: Wed, 25 Sep 2024 11:56:29 +0000 (+0200) Subject: Einheitliche Benennung des Producers -- ALIGN X-Git-Tag: grundlagen/simple-producer--BRANCH-ENDE~8 X-Git-Url: https://juplo.de/gitweb/?a=commitdiff_plain;h=373e8e7cf3f64a319517d9bab2cc14b9d6bf101f;p=demos%2Fkafka%2Ftraining Einheitliche Benennung des Producers -- ALIGN --- 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);