Skip to content

Commit 9c8e7a4

Browse files
committed
cleanup from PR review
1 parent a13c9c0 commit 9c8e7a4

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/ShareRecordMessagingMessageListenerAdapter.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,6 +26,7 @@
2626
import org.springframework.kafka.listener.AcknowledgingShareConsumerAwareMessageListener;
2727
import org.springframework.kafka.listener.KafkaListenerErrorHandler;
2828
import org.springframework.kafka.support.ShareAcknowledgment;
29+
import org.springframework.kafka.support.converter.JacksonProjectingMessageConverter;
2930
import org.springframework.kafka.support.converter.RecordMessageConverter;
3031
import org.springframework.messaging.Message;
3132

@@ -75,7 +76,7 @@ public void onShareRecord(ConsumerRecord<K, V> record, @Nullable ShareAcknowledg
7576
}
7677
if (logger.isDebugEnabled()) {
7778
RecordMessageConverter messageConverter = getMessageConverter();
78-
if (!(messageConverter instanceof org.springframework.kafka.support.converter.JacksonProjectingMessageConverter
79+
if (!(messageConverter instanceof JacksonProjectingMessageConverter
7980
|| messageConverter instanceof org.springframework.kafka.support.converter.ProjectingMessageConverter)) {
8081
this.logger.debug("Processing [" + message + "]");
8182
}

0 commit comments

Comments
 (0)