Flag `running` in `stopped` umbenannt

diff --git a/src/main/java/de/juplo/kafka/ExampleConsumer.java b/src/main/java/de/juplo/kafka/ExampleConsumer.java
index 3b24b58ffaea4d38be73d45fe8064a031c989105..eb606d7fa8d6ac439ce6a0d1ed26b538697ed6fd 100644 (file)
--- a/src/main/java/de/juplo/kafka/ExampleConsumer.java
+++ b/src/main/java/de/juplo/kafka/ExampleConsumer.java
@@ -23,7 +23,8 @@ public class ExampleConsumer implements ConsumerRebalanceListener
   private final String topic;
   private final Consumer<String, String> consumer;
 
-  private volatile boolean running = false;
+  private volatile boolean stopped = false;
+
   private long consumed = 0;
 
   public ExampleConsumer(
@@ -51,7 +52,6 @@ public class ExampleConsumer implements ConsumerRebalanceListener
     {
       log.info("{} - Subscribing to topic {}", id, topic);
       consumer.subscribe(Arrays.asList(topic), this);
-      running = true;
 
       while (true)
       {
@@ -83,7 +83,7 @@ public class ExampleConsumer implements ConsumerRebalanceListener
       log.info("{} - Closing the KafkaConsumer", id);
       consumer.close();
       log.info("{} - Consumed {} messages in total, exiting!", id, consumed);
-      running = false;
+      stopped = true;
     }
   }
 
@@ -148,9 +148,10 @@ public class ExampleConsumer implements ConsumerRebalanceListener
 
     Runtime.getRuntime().addShutdownHook(new Thread(() ->
     {
+      log.info("{} - Stopping the poll-loop...", instance.id);
       instance.consumer.wakeup();
 
-      while (instance.running)
+      while (!instance.stopped)
       {
         log.info("{} - Waiting for main-thread...", instance.id);
         try