From 41fb1c0fd3612c4c29f415c41b281bc432237827 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Sun, 22 Mar 2026 15:26:39 +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/ExampleConsumer.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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(); -- 2.39.5