From c9f081e3685a1be549a4f68cec90e5ba50df03e0 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Sun, 22 Mar 2026 15:25:43 +0100
Subject: [PATCH] =?utf8?q?Client-ID=20in=20Shutdown-Meldungen=20erg=C3=A4n?=
 =?utf8?q?zt?=
MIME-Version: 1.0
Content-Type: text/plain; charset=utf8
Content-Transfer-Encoding: 8bit

---
 src/main/java/de/juplo/kafka/ExampleProducer.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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();
-- 
2.39.5