From: Kai Moritz <kai@juplo.de>
Date: Sat, 15 Mar 2025 18:12:05 +0000 (+0100)
Subject: Das `running`-Flag wird nicht mehr benötigt
X-Git-Tag: consumer/spring-consumer--2025-03-18--19-42
X-Git-Url: https://juplo.de/gitweb/?a=commitdiff_plain;h=a0b57935f28ff910bfe2121822e2cbb1673d4ac3;p=demos%2Fkafka%2Ftraining

Das `running`-Flag wird nicht mehr benötigt
---

diff --git a/src/main/java/de/juplo/kafka/ExampleConsumer.java b/src/main/java/de/juplo/kafka/ExampleConsumer.java
index 4f7151fb..1f5a5706 100644
--- a/src/main/java/de/juplo/kafka/ExampleConsumer.java
+++ b/src/main/java/de/juplo/kafka/ExampleConsumer.java
@@ -19,7 +19,6 @@ public class ExampleConsumer implements Runnable
   private final Thread workerThread;
   private final Runnable closeCallback;
 
-  private volatile boolean running = false;
   private long consumed = 0;
 
 
@@ -47,9 +46,8 @@ public class ExampleConsumer implements Runnable
     {
       log.info("{} - Subscribing to topic {}", id, topic);
       consumer.subscribe(Arrays.asList(topic));
-      running = true;
 
-      while (running)
+      while (true)
       {
         ConsumerRecords<String, String> records = consumer.poll(Duration.ofSeconds(1));
 
@@ -98,9 +96,9 @@ public class ExampleConsumer implements Runnable
 
   public void shutdown() throws InterruptedException
   {
-    log.info("{} joining the worker-thread...", id);
-    running = false;
+    log.info("{} - Waking up the consumer", id);
     consumer.wakeup();
+    log.info("{} - Joining the worker thread", id);
     workerThread.join();
   }
 }