From a0b57935f28ff910bfe2121822e2cbb1673d4ac3 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Sat, 15 Mar 2025 19:12:05 +0100 Subject: [PATCH] =?utf8?q?Das=20`running`-Flag=20wird=20nicht=20mehr=20ben?= =?utf8?q?=C3=B6tigt?= MIME-Version: 1.0 Content-Type: text/plain; charset=utf8 Content-Transfer-Encoding: 8bit --- src/main/java/de/juplo/kafka/ExampleConsumer.java | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) diff --git a/src/main/java/de/juplo/kafka/ExampleConsumer.java b/src/main/java/de/juplo/kafka/ExampleConsumer.java index 4f7151fb..1f5a5706 100644 --- a/src/main/java/de/juplo/kafka/ExampleConsumer.java +++ b/src/main/java/de/juplo/kafka/ExampleConsumer.java @@ -19,7 +19,6 @@ public class ExampleConsumer implements Runnable private final Thread workerThread; private final Runnable closeCallback; - private volatile boolean running = false; private long consumed = 0; @@ -47,9 +46,8 @@ public class ExampleConsumer implements Runnable { log.info("{} - Subscribing to topic {}", id, topic); consumer.subscribe(Arrays.asList(topic)); - running = true; - while (running) + while (true) { ConsumerRecords records = consumer.poll(Duration.ofSeconds(1)); @@ -98,9 +96,9 @@ public class ExampleConsumer implements Runnable public void shutdown() throws InterruptedException { - log.info("{} joining the worker-thread...", id); - running = false; + log.info("{} - Waking up the consumer", id); consumer.wakeup(); + log.info("{} - Joining the worker thread", id); workerThread.join(); } } -- 2.20.1