Fehlerhafte Commit-Logik: Immer `producer.close()`

diff --git a/src/main/java/de/juplo/kafka/EndlessConsumer.java b/src/main/java/de/juplo/kafka/EndlessConsumer.java
index 9ea944b9039812dd3c0a6d4f1dcd10286d1f67bf..a7ae35b8d1781e2af6a124cc5596ef5642912064 100644 (file)
--- a/src/main/java/de/juplo/kafka/EndlessConsumer.java
+++ b/src/main/java/de/juplo/kafka/EndlessConsumer.java
@@ -84,8 +84,6 @@ public class EndlessConsumer<K, V> implements Runnable
     {
       log.error("{} - Unexpected error: {}", id, e.toString(), e);
       this.exception = e;
-      log.info("{} - Unsubscribing...", id);
-      consumer.unsubscribe();
     }
     finally
     {