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

chia7712 pushed a commit to branch 3.9
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/3.9 by this push:
     new 5507c22b458 KAFKA-12456 Log 'Listeners are not identical across 
brokers' message at INFO instead of ERROR (#20404)
5507c22b458 is described below

commit 5507c22b458367161fe854738100579bf54f79ec
Author: Kuan-Po Tseng <[email protected]>
AuthorDate: Tue Aug 26 11:14:54 2025 +0800

    KAFKA-12456 Log 'Listeners are not identical across brokers' message at 
INFO instead of ERROR (#20404)
    
    Lower the log level to INFO instead of ERROR.
    
    Reviewers: Chia-Ping Tsai <[email protected]>
---
 core/src/main/scala/kafka/server/metadata/ZkMetadataCache.scala | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/core/src/main/scala/kafka/server/metadata/ZkMetadataCache.scala 
b/core/src/main/scala/kafka/server/metadata/ZkMetadataCache.scala
index 20de08d2401..cda34dd99f8 100755
--- a/core/src/main/scala/kafka/server/metadata/ZkMetadataCache.scala
+++ b/core/src/main/scala/kafka/server/metadata/ZkMetadataCache.scala
@@ -542,7 +542,7 @@ class ZkMetadataCache(
       aliveNodes.get(brokerId).foreach { listenerMap =>
         val listeners = listenerMap.keySet
         if (!aliveNodes.values.forall(_.keySet == listeners))
-          error(s"Listeners are not identical across brokers: $aliveNodes")
+          info(s"Listeners are not identical across brokers: $aliveNodes")
       }
 
       val topicIds = mutable.Map.empty[String, Uuid]

Reply via email to