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