diff --git a/spring-pulsar/src/main/java/org/springframework/pulsar/listener/DefaultPulsarMessageListenerContainer.java b/spring-pulsar/src/main/java/org/springframework/pulsar/listener/DefaultPulsarMessageListenerContainer.java index 8c6b1e93..eb2e8eb8 100644 --- a/spring-pulsar/src/main/java/org/springframework/pulsar/listener/DefaultPulsarMessageListenerContainer.java +++ b/spring-pulsar/src/main/java/org/springframework/pulsar/listener/DefaultPulsarMessageListenerContainer.java @@ -493,6 +493,8 @@ public class DefaultPulsarMessageListenerContainer extends AbstractPulsarMess inRetryMode.compareAndSet(true, false); } catch (Exception e) { + DefaultPulsarMessageListenerContainer.this.logger.debug(e, + () -> "Error dispatching the message to the listener."); if (this.pulsarConsumerErrorHandler != null) { invokeRecordListenerErrorHandler(inRetryMode, message, e); }