diff --git a/spring-kafka/src/main/java/org/springframework/kafka/listener/adapter/RecordMessagingMessageListenerAdapter.java b/spring-kafka/src/main/java/org/springframework/kafka/listener/adapter/RecordMessagingMessageListenerAdapter.java index 8eb521ce..6e3607fe 100644 --- a/spring-kafka/src/main/java/org/springframework/kafka/listener/adapter/RecordMessagingMessageListenerAdapter.java +++ b/spring-kafka/src/main/java/org/springframework/kafka/listener/adapter/RecordMessagingMessageListenerAdapter.java @@ -25,6 +25,7 @@ import org.springframework.kafka.listener.AcknowledgingConsumerAwareMessageListe import org.springframework.kafka.listener.KafkaListenerErrorHandler; import org.springframework.kafka.listener.ListenerExecutionFailedException; import org.springframework.kafka.support.Acknowledgment; +import org.springframework.kafka.support.converter.ProjectingMessageConverter; import org.springframework.messaging.Message; import org.springframework.messaging.support.GenericMessage; @@ -79,7 +80,7 @@ public class RecordMessagingMessageListenerAdapter extends MessagingMessag else { message = NULL_MESSAGE; } - if (logger.isDebugEnabled()) { + if (logger.isDebugEnabled() && !(getMessageConverter() instanceof ProjectingMessageConverter)) { logger.debug("Processing [" + message + "]"); } try {