From 79ff69fe7d5784ca94d7b5039590d5dd1fe9f3bb Mon Sep 17 00:00:00 2001 From: Ryan Swech Date: Wed, 16 Apr 2025 14:17:56 -0400 Subject: [PATCH] Fix MessagingMessageListenerAdapter Error swallowing Fixes: #3843 Signed-off-by: ryanswech <102254634+ryanswech@users.noreply.github.com> --- .../kafka/listener/adapter/MessagingMessageListenerAdapter.java | 1 + 1 file changed, 1 insertion(+) diff --git a/spring-kafka/src/main/java/org/springframework/kafka/listener/adapter/MessagingMessageListenerAdapter.java b/spring-kafka/src/main/java/org/springframework/kafka/listener/adapter/MessagingMessageListenerAdapter.java index 637715171e..aaa81e6fa8 100644 --- a/spring-kafka/src/main/java/org/springframework/kafka/listener/adapter/MessagingMessageListenerAdapter.java +++ b/spring-kafka/src/main/java/org/springframework/kafka/listener/adapter/MessagingMessageListenerAdapter.java @@ -432,6 +432,7 @@ protected void invoke(Object records, @Nullable Acknowledgment acknowledgment, @ catch (Error e) { listenerError = e; currentObservation.error(e); + throw e; } finally { if (listenerError != null || result == null) {