From 737ed2532dca5aca9140c0dc5f6f054d69fa8ea6 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Sun, 20 Sep 2026 09:26:26 +0200 Subject: [PATCH] Flag `running` in `stopped` umbenannt --- src/main/java/de/juplo/kafka/ExampleConsumer.java | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/src/main/java/de/juplo/kafka/ExampleConsumer.java b/src/main/java/de/juplo/kafka/ExampleConsumer.java index 3b24b58f..eb606d7f 100644 --- a/src/main/java/de/juplo/kafka/ExampleConsumer.java +++ b/src/main/java/de/juplo/kafka/ExampleConsumer.java @@ -23,7 +23,8 @@ public class ExampleConsumer implements ConsumerRebalanceListener private final String topic; private final Consumer consumer; - private volatile boolean running = false; + private volatile boolean stopped = false; + private long consumed = 0; public ExampleConsumer( @@ -51,7 +52,6 @@ public class ExampleConsumer implements ConsumerRebalanceListener { log.info("{} - Subscribing to topic {}", id, topic); consumer.subscribe(Arrays.asList(topic), this); - running = true; while (true) { @@ -83,7 +83,7 @@ public class ExampleConsumer implements ConsumerRebalanceListener log.info("{} - Closing the KafkaConsumer", id); consumer.close(); log.info("{} - Consumed {} messages in total, exiting!", id, consumed); - running = false; + stopped = true; } } @@ -148,9 +148,10 @@ public class ExampleConsumer implements ConsumerRebalanceListener Runtime.getRuntime().addShutdownHook(new Thread(() -> { + log.info("{} - Stopping the poll-loop...", instance.id); instance.consumer.wakeup(); - while (instance.running) + while (!instance.stopped) { log.info("{} - Waiting for main-thread...", instance.id); try -- 2.39.5