Einheitliche Benennung des Consumers -- ALIGN

diff --git a/pom.xml b/pom.xml
index 327625b..7b7363d 100644 (file)
--- a/pom.xml
+++ b/pom.xml
@@ -62,7 +62,7 @@
             <manifest>
               <addClasspath>true</addClasspath>
               <classpathPrefix>libs/</classpathPrefix>
-              <mainClass>de.juplo.kafka.SimpleConsumer</mainClass>
+              <mainClass>de.juplo.kafka.ExampleConsumer</mainClass>
             </manifest>
           </archive>
         </configuration>

diff --git a/src/main/java/de/juplo/kafka/ExampleConsumer.java b/src/main/java/de/juplo/kafka/ExampleConsumer.java
index cee2165..1715813 100644 (file)
--- a/src/main/java/de/juplo/kafka/ExampleConsumer.java
+++ b/src/main/java/de/juplo/kafka/ExampleConsumer.java
@@ -14,7 +14,7 @@ import java.util.Properties;
 
 
 @Slf4j
-public class SimpleConsumer
+public class ExampleConsumer
 {
   private final String id;
   private final String topic;
@@ -23,7 +23,7 @@ public class SimpleConsumer
   private volatile boolean running = false;
   private long consumed = 0;
 
-  public SimpleConsumer(String broker, String topic, String groupId, String clientId)
+  public ExampleConsumer(String broker, String topic, String groupId, String clientId)
   {
     Properties props = new Properties();
     props.put("bootstrap.servers", broker);
@@ -108,7 +108,7 @@ public class SimpleConsumer
     }
 
 
-    SimpleConsumer instance = new SimpleConsumer(broker, topic, groupId, clientId);
+    ExampleConsumer instance = new ExampleConsumer(broker, topic, groupId, clientId);
 
     Runtime.getRuntime().addShutdownHook(new Thread(() ->
     {