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

[demos/kafka/training] / src / main / java / de / juplo / kafka / EndlessConsumer.java

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