From a0b57935f28ff910bfe2121822e2cbb1673d4ac3 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
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<String, String> 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