From 03f7f05203cd84177c6c18dd3a4becbad6732585 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Sun, 25 May 2025 13:53:27 +0200 Subject: [PATCH] =?utf8?q?`@EventListener`=20f=C3=BCr=20Start-Fehler=20und?= =?utf8?q?=20Stop=20erg=C3=A4nzt?= MIME-Version: 1.0 Content-Type: text/plain; charset=utf8 Content-Transfer-Encoding: 8bit --- src/main/java/de/juplo/kafka/Application.java | 17 +++++++++++++++++ 1 file changed, 17 insertions(+) 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); -- 2.20.1