From 21852945c15e0ea25b6141c79e493de7a0f94329 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Sat, 21 Mar 2026 17:55:27 +0100
Subject: [PATCH] Anwendung nur beenden, wenn der Consumer nicht normal
 gestoppt wurde

---
 src/main/java/de/juplo/kafka/Application.java | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/src/main/java/de/juplo/kafka/Application.java b/src/main/java/de/juplo/kafka/Application.java
index c85280af..ea489e07 100644
--- 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)
-- 
2.39.5