WIP

diff --git a/src/main/java/de/juplo/kafka/ExampleConsumer.java b/src/main/java/de/juplo/kafka/ExampleConsumer.java
index 0fbddc8dbbbe3900d9a190592f9694ef5958693d..c63ca7e9508fdafd1616ca6da983cd01b9c4ed59 100644 (file)
--- 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
     {