From: Kai Moritz <kai@juplo.de>
Date: Sun, 25 May 2025 11:53:27 +0000 (+0200)
Subject: `@EventListener` für Start-Fehler und Stop ergänzt
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=03f7f05203cd84177c6c18dd3a4becbad6732585;p=demos%2Fkafka%2Ftraining

`@EventListener` für Start-Fehler und Stop ergänzt
---

diff --git a/src/main/java/de/juplo/kafka/Application.java b/src/main/java/de/juplo/kafka/Application.java
index 0069257..c85280a 100644
--- a/src/main/java/de/juplo/kafka/Application.java
+++ b/src/main/java/de/juplo/kafka/Application.java
@@ -1,12 +1,29 @@
 package de.juplo.kafka;
 
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.context.event.EventListener;
+import org.springframework.kafka.event.ConsumerFailedToStartEvent;
+import org.springframework.kafka.event.ConsumerStoppedEvent;
 
 
 @SpringBootApplication
+@Slf4j
 public class Application
 {
+  @EventListener
+  public void handleConsumerFailedToStartEvent(ConsumerFailedToStartEvent event) {
+    log.error("Kafka consumer failed to start: {}", event);
+    System.exit(1);
+  }
+
+  @EventListener
+  public void handleConsumerStoppedEvent(ConsumerStoppedEvent event) {
+    log.info("Kafka consumer stopped: {}", event);
+    System.exit(1);
+  }
+
   public static void main(String[] args)
   {
     SpringApplication.run(Application.class, args);