From: Kai Moritz <kai@juplo.de>
Date: Sun, 20 Sep 2026 07:26:26 +0000 (+0200)
Subject: Flag `running` in `stopped` umbenannt
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=737ed2532dca5aca9140c0dc5f6f054d69fa8ea6;p=demos%2Fkafka%2Ftraining

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 3b24b58f..eb606d7f 100644
--- 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