`@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 (file)
--- 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);