Anwendung nur beenden, wenn der Consumer nicht normal gestoppt wurde

diff --git a/src/main/java/de/juplo/kafka/Application.java b/src/main/java/de/juplo/kafka/Application.java
index c85280af764bcd2031a7b245712c230207bb61b8..ea489e07447bcd1f95d55daafbda68a4b176dc90 100644 (file)
--- a/src/main/java/de/juplo/kafka/Application.java
+++ b/src/main/java/de/juplo/kafka/Application.java
@@ -21,7 +21,11 @@ public class Application
   @EventListener
   public void handleConsumerStoppedEvent(ConsumerStoppedEvent event) {
     log.info("Kafka consumer stopped: {}", event);
-    System.exit(1);
+    if (event.getReason() != ConsumerStoppedEvent.Reason.NORMAL)
+    {
+      log.error("Kafka consumer was not stopped normally: {}. Exiting!", event.getReason());
+      System.exit(1);
+    }
   }
 
   public static void main(String[] args)