Einheitliche Benennung des Producers -- ALIGN

diff --git a/pom.xml b/pom.xml
index 2928676..02e80d3 100644 (file)
--- a/pom.xml
+++ b/pom.xml
@@ -61,7 +61,7 @@
             <manifest>
               <addClasspath>true</addClasspath>
               <classpathPrefix>libs/</classpathPrefix>
-              <mainClass>de.juplo.kafka.SimpleProducer</mainClass>
+              <mainClass>de.juplo.kafka.ExampleProducer</mainClass>
             </manifest>
           </archive>
         </configuration>

diff --git a/src/main/java/de/juplo/kafka/ExampleProducer.java b/src/main/java/de/juplo/kafka/ExampleProducer.java
index db554d7..51178f5 100644 (file)
--- 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);