Skip to content

Commit bef69c3

Browse files
authored
GH-3843: Fix MessagingMessageListenerAdapter Error swallowing
Fixes: #3843 Issue link: #3843 Signed-off-by: Ryan Swech <[email protected]> [[email protected] Improve commit message] **Auto-cherry-pick to `3.3.x`** Signed-off-by: Artem Bilan <[email protected]>
1 parent c3fc82b commit bef69c3

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

spring-kafka/src/main/java/org/springframework/kafka/listener/adapter/MessagingMessageListenerAdapter.java

+1
Original file line numberDiff line numberDiff line change
@@ -432,6 +432,7 @@ protected void invoke(Object records, @Nullable Acknowledgment acknowledgment, @
432432
catch (Error e) {
433433
listenerError = e;
434434
currentObservation.error(e);
435+
throw e;
435436
}
436437
finally {
437438
if (listenerError != null || result == null) {

0 commit comments

Comments
 (0)