Spring/spring-kafka
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Don't Log Converted Message With Projection

Browse Source 
`toString()` cannot be invoked on the payload proxy created by
the project factory.
This commit is contained in:
Gary Russell
2021-03-22 13:39:17 -04:00
parent 27d06cc42f
commit 317fbcc8bd
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -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<K, V> extends MessagingMessag
else {
message = NULL_MESSAGE;
}
if (logger.isDebugEnabled()) {
if (logger.isDebugEnabled() && !(getMessageConverter() instanceof ProjectingMessageConverter)) {
logger.debug("Processing [" + message + "]");
}
try {