From 1d16784ec710e5dcaa49aabbd0174c1eff8f6bb2 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Sat, 2 Nov 2024 22:29:31 +0100
Subject: [PATCH] WIP

---
 src/main/java/de/juplo/kafka/ExampleConsumer.java | 1 -
 1 file changed, 1 deletion(-)

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
     {
-- 
2.20.1