From caca5c4b79744c3df4efdccd86ecd8b138578d17 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Sun, 18 Sep 2022 12:02:23 +0200
Subject: [PATCH] Fehlerhafte Commit-Logik: Immer `producer.close()`

---
 src/main/java/de/juplo/kafka/EndlessConsumer.java | 2 --
 1 file changed, 2 deletions(-)

diff --git a/src/main/java/de/juplo/kafka/EndlessConsumer.java b/src/main/java/de/juplo/kafka/EndlessConsumer.java
index 9ea944b..a7ae35b 100644
--- 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
     {
-- 
2.20.1