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 60424bc319ab2bbf0ba78b71a44e4fd5b4f0db54..a76458890f62b9c25ccc571a77a4f4821fb6fa9f 100644 (file)
--- 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();