Improve warning message for ConsumerRecords filter strategy (#3556)

spring-projects · Oct 14, 2024 · 3d507c7 · 3d507c7
1 parent 6f4adb2
commit 3d507c7
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/...g-kafka/src/main/java/org/springframework/kafka/config/AbstractKafkaListenerEndpoint.java b/...g-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<K, V>) 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<>(