From: Kai Moritz <kai@juplo.de>
Date: Sat, 2 Nov 2024 21:29:31 +0000 (+0100)
Subject: WIP
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=1d16784ec710e5dcaa49aabbd0174c1eff8f6bb2;p=demos%2Fkafka%2Ftraining

WIP
---

diff --git a/src/main/java/de/juplo/kafka/ExampleConsumer.java b/src/main/java/de/juplo/kafka/ExampleConsumer.java
index 0fbddc8..c63ca7e 100644
--- a/src/main/java/de/juplo/kafka/ExampleConsumer.java
+++ b/src/main/java/de/juplo/kafka/ExampleConsumer.java
@@ -160,7 +160,6 @@ public class ExampleConsumer implements Runnable, ConsumerRebalanceListener
       producer.abortTransaction();
       log.info("{} - Triggering exit of application!", id);
       new Thread(closeCallback).start();
-      return;
     }
     finally
     {