From ceb3caf09c5b8594493c6d98a1dd06f178b5f2d0 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Wed, 13 Apr 2022 23:09:49 +0200 Subject: [PATCH] =?utf8?q?Springify:=20`CommonContainerStoppingErrorHandle?= =?utf8?q?r`=20f=C3=BCr=20erwartetes=20Verhalten?= MIME-Version: 1.0 Content-Type: text/plain; charset=utf8 Content-Transfer-Encoding: 8bit * Der `CommonContainerStoppingErrorHandler` stoppt den Container beim ersten Auftreten eines Fehlers. * Dadurch ist das erwartete Verhalten - soweit bisher durch die Tests definiert - wiederhergestellt. * Der Handler wird den Container aber auch bei einem Fehler im Listener stoppen, so dass in dem Fall wahrscheinlich noch nachgebessert werden muss. --- src/main/java/de/juplo/kafka/ApplicationConfiguration.java | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java index 5cefa32..fd4ff28 100644 --- a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java +++ b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java @@ -4,6 +4,7 @@ import org.apache.kafka.clients.consumer.ConsumerRecord; import org.springframework.boot.context.properties.EnableConfigurationProperties; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; +import org.springframework.kafka.listener.CommonContainerStoppingErrorHandler; import java.util.function.Consumer; @@ -20,4 +21,10 @@ public class ApplicationConfiguration // Handle record }; } + + @Bean + public CommonContainerStoppingErrorHandler errorHandler() + { + return new CommonContainerStoppingErrorHandler(); + } } -- 2.20.1