diff --git a/spring-kafka/src/main/java/org/springframework/kafka/config/AbstractKafkaListenerEndpoint.java b/spring-kafka/src/main/java/org/springframework/kafka/config/AbstractKafkaListenerEndpoint.java index 4b7cf8c97c..6cc3d0e780 100644 --- a/spring-kafka/src/main/java/org/springframework/kafka/config/AbstractKafkaListenerEndpoint.java +++ b/spring-kafka/src/main/java/org/springframework/kafka/config/AbstractKafkaListenerEndpoint.java @@ -63,6 +63,7 @@ * @author Artem Bilan * @author Wang Zhiyang * @author Sanghyeok An + * @author Borahm Lee * * @see MethodKafkaListenerEndpoint */ @@ -537,8 +538,8 @@ private void setupMessageListener(MessageListenerContainer container, if (this.recordFilterStrategy != null) { if (isBatchListener()) { if (((MessagingMessageListenerAdapter) messageListener).isConsumerRecords()) { - this.logger.warn(() -> "Filter strategy ignored when consuming 'ConsumerRecords' instead of a List" - + (this.id != null ? " id: " + this.id : "")); + this.logger.warn(() -> "Filter strategy is ignored when consuming 'ConsumerRecords' directly instead of a List of records." + + (this.id != null ? " listenerId: " + this.id : "")); } else { messageListener = new FilteringBatchMessageListenerAdapter<>(