From: Kai Moritz <kai@juplo.de>
Date: Sat, 21 Mar 2026 16:55:27 +0000 (+0100)
Subject: Anwendung nur beenden, wenn der Consumer nicht normal gestoppt wurde
X-Git-Tag: springkafka/spring-consumer--kafkahandler--2026-03-lvm
X-Git-Url: https://juplo.de/gitweb/?a=commitdiff_plain;h=380b88c893078897bef0b0f274ca862a09b36075;p=demos%2Fkafka%2Ftraining

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 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)