Skip to content

Commit 2d95538

Browse files
committed
Don't Log Converted Message With Projection
`toString()` cannot be invoked on the payload proxy created by the project factory.
1 parent 45bddc8 commit 2d95538

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

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

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,6 +25,7 @@
2525
import org.springframework.kafka.listener.KafkaListenerErrorHandler;
2626
import org.springframework.kafka.listener.ListenerExecutionFailedException;
2727
import org.springframework.kafka.support.Acknowledgment;
28+
import org.springframework.kafka.support.converter.ProjectingMessageConverter;
2829
import org.springframework.messaging.Message;
2930
import org.springframework.messaging.support.GenericMessage;
3031

@@ -79,7 +80,7 @@ public void onMessage(ConsumerRecord<K, V> record, Acknowledgment acknowledgment
7980
else {
8081
message = NULL_MESSAGE;
8182
}
82-
if (logger.isDebugEnabled()) {
83+
if (logger.isDebugEnabled() && !(getMessageConverter() instanceof ProjectingMessageConverter)) {
8384
logger.debug("Processing [" + message + "]");
8485
}
8586
try {

0 commit comments

Comments
 (0)