Fehler beim Beenden korrigiert: `running = false` zu früh!

diff --git a/src/main/java/de/juplo/kafka/ExampleConsumer.java b/src/main/java/de/juplo/kafka/ExampleConsumer.java
index c152cfb1df1648c2cc3246ce4b89a17da81a2e2e..6f4e4e88091a31b6c6a325d817c856a17943c9a1 100644 (file)
--- a/src/main/java/de/juplo/kafka/ExampleConsumer.java
+++ b/src/main/java/de/juplo/kafka/ExampleConsumer.java
@@ -77,10 +77,10 @@ public class ExampleConsumer
     }
     finally
     {
-      running = false;
       log.info("{} - Closing the KafkaConsumer", id);
       consumer.close();
       log.info("{}: Consumed {} messages in total, exiting!", id, consumed);
+      running = false;
     }
   }
 
@@ -138,4 +138,4 @@ public class ExampleConsumer
     instance.run();
   }
 }
-  
+