From: Kai Moritz <kai@juplo.de>
Date: Sun, 22 Mar 2026 14:26:39 +0000 (+0100)
Subject: Client-ID in Shutdown-Meldungen ergänzt
X-Git-Tag: grundlagen/simple-consumer--2026-03-22--20-47
X-Git-Url: https://juplo.de/gitweb/?a=commitdiff_plain;h=41fb1c0fd3612c4c29f415c41b281bc432237827;p=demos%2Fkafka%2Ftraining

Client-ID in Shutdown-Meldungen ergänzt
---

diff --git a/src/main/java/de/juplo/kafka/ExampleConsumer.java b/src/main/java/de/juplo/kafka/ExampleConsumer.java
index 7be827ef..6f4e4e88 100644
--- a/src/main/java/de/juplo/kafka/ExampleConsumer.java
+++ b/src/main/java/de/juplo/kafka/ExampleConsumer.java
@@ -125,14 +125,14 @@ public class ExampleConsumer
 
       while (instance.running)
       {
-        log.info("Waiting for main-thread...");
+        log.info("{} - Waiting for main-thread...", instance.id);
         try
         {
           Thread.sleep(1000);
         }
         catch (InterruptedException e) {}
       }
-      log.info("Shutdown completed.");
+      log.info("{} - Shutdown completed.", instance.id);
     }));
 
     instance.run();