From: Kai Moritz <kai@juplo.de>
Date: Sun, 18 Sep 2022 10:02:23 +0000 (+0200)
Subject: Fehlerhafte Commit-Logik: Immer `producer.close()`
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=caca5c4b79744c3df4efdccd86ecd8b138578d17;p=demos%2Fkafka%2Ftraining

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