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

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

diff --git a/src/main/java/de/juplo/kafka/ExampleProducer.java b/src/main/java/de/juplo/kafka/ExampleProducer.java
index 60424bc3..a7645889 100644
--- a/src/main/java/de/juplo/kafka/ExampleProducer.java
+++ b/src/main/java/de/juplo/kafka/ExampleProducer.java
@@ -139,14 +139,14 @@ public class ExampleProducer
       instance.running = false;
       while (!instance.done)
       {
-        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();