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-Tag: sumup-adder--json--vorlage---lvm-2-tage~2
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;ds=sidebyside;h=b6d6088a42ac280c60aa65eac85dbeefc1e45077;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
     {