(flink-connector-kafka) branch main updated: [FLINK-37304][connector/kafka] Downgrade the log level of metadataUpdateEvent in DynamicKafkaSourceEnumerator to avoid displaying connection information

[leonard]

This is an automated email from the ASF dual-hosted git repository.

leonard pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-kafka.git


The following commit(s) were added to refs/heads/main by this push:
     new 1b9b1aa3 [FLINK-37304][connector/kafka] Downgrade the log level of 
metadataUpdateEvent in DynamicKafkaSourceEnumerator to avoid displaying 
connection information
1b9b1aa3 is described below

commit 1b9b1aa3224a81888e740d8a4b06119639ad27f3
Author: Kunni <lvyanquan....@alibaba-inc.com>
AuthorDate: Thu Apr 3 14:34:43 2025 +0800

    [FLINK-37304][connector/kafka] Downgrade the log level of 
metadataUpdateEvent in DynamicKafkaSourceEnumerator to avoid displaying 
connection information
    
    This closes #153.
---
 .../dynamic/source/enumerator/DynamicKafkaSourceEnumerator.java      | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git 
a/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator/DynamicKafkaSourceEnumerator.java
 
b/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator/DynamicKafkaSourceEnumerator.java
index b61cee40..48e1c78d 100644
--- 
a/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator/DynamicKafkaSourceEnumerator.java
+++ 
b/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator/DynamicKafkaSourceEnumerator.java
@@ -347,7 +347,7 @@ public class DynamicKafkaSourceEnumerator
     private void sendMetadataUpdateEventToAvailableReaders() {
         for (int readerId : enumContext.registeredReaders().keySet()) {
             MetadataUpdateEvent metadataUpdateEvent = new 
MetadataUpdateEvent(latestKafkaStreams);
-            logger.info("sending metadata update to reader {}: {}", readerId, 
metadataUpdateEvent);
+            logger.debug("sending metadata update to reader {}: {}", readerId, 
metadataUpdateEvent);
             enumContext.sendEventToSourceReader(readerId, metadataUpdateEvent);
         }
     }
@@ -517,7 +517,8 @@ public class DynamicKafkaSourceEnumerator
 
         if (enumContext.registeredReaders().containsKey(subtaskId)) {
             MetadataUpdateEvent metadataUpdateEvent = new 
MetadataUpdateEvent(latestKafkaStreams);
-            logger.info("sending metadata update to reader {}: {}", subtaskId, 
metadataUpdateEvent);
+            logger.debug(
+                    "sending metadata update to reader {}: {}", subtaskId, 
metadataUpdateEvent);
             enumContext.sendEventToSourceReader(subtaskId, 
metadataUpdateEvent);
         } else {
             logger.warn("Got get metadata update but subtask was unavailable");