From: Kai Moritz <kai@juplo.de>
Date: Tue, 1 Apr 2025 21:41:24 +0000 (+0200)
Subject: Ordentlich mit `instance.consumer.wakeup()`
X-Git-Tag: grundlagen/simple-consumer--livecoding--schritte--2025-05-lvm
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=refs%2Fheads%2Fgrundlagen%2Fsimple-consumer--livecoding--schritte;p=demos%2Fkafka%2Ftraining

Ordentlich mit `instance.consumer.wakeup()`
---

diff --git a/src/main/java/de/juplo/kafka/ExampleConsumer.java b/src/main/java/de/juplo/kafka/ExampleConsumer.java
index bc9a8f8..e47c399 100644
--- a/src/main/java/de/juplo/kafka/ExampleConsumer.java
+++ b/src/main/java/de/juplo/kafka/ExampleConsumer.java
@@ -71,6 +71,12 @@ public class ExampleConsumer
         }
       }
     }
+    catch(WakeupException e)
+    {
+      log.info("{}: Wakeup!", id);
+      consumer.close();
+      running = false;
+    }
     finally
     {
       log.info("{}: Consumed {} messages in total, exiting!", id, consumed);
@@ -92,7 +98,7 @@ public class ExampleConsumer
     {
       while(instance.running)
       {
-        instance.consumer.close();
+        instance.consumer.wakeup();
 
         try
         {