X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FSimpleConsumer.java;h=5557a4d7775e31a0f64fc7a8d305b38dbba47113;hb=d0ec626f3f7bdf72824b028a8341edf79540f756;hp=cab2fb8d18dda167033ffdab59196d7ba98b7535;hpb=fc97fc7bb1b7219329183cdbfc0e861375a3cb04;p=demos%2Fkafka%2Ftraining

diff --git a/src/main/java/de/juplo/kafka/SimpleConsumer.java b/src/main/java/de/juplo/kafka/SimpleConsumer.java
index cab2fb8..5557a4d 100644
--- a/src/main/java/de/juplo/kafka/SimpleConsumer.java
+++ b/src/main/java/de/juplo/kafka/SimpleConsumer.java
@@ -75,7 +75,8 @@ public class SimpleConsumer
     }
     catch(Exception e)
     {
-      log.error("{} - Unexpected error: {}", id, e.toString());
+      log.error("{} - Unexpected error: {}, unsubscribing!", id, e.toString());
+      consumer.unsubscribe();
     }
     finally
     {