KAFKA-12456 Log 'Listeners are not identical across brokers' message at INFO instead of ERROR (apache#20404)

brandboat · web-flow · commit 5507c22b4583 · 2025-08-26T11:14:54.000+08:00
Lower the log level to INFO instead of ERROR.

Reviewers: Chia-Ping Tsai &lt;chia7712@gmail.com&gt;
diff --git 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]

Original file line number	Diff line number	Diff line change
`@@ -542,7 +542,7 @@ class ZkMetadataCache(`
`542`	`542`	`aliveNodes.get(brokerId).foreach { listenerMap =>`
`543`	`543`	`val listeners = listenerMap.keySet`
`544`	`544`	`if (!aliveNodes.values.forall(_.keySet == listeners))`
`545`		`- error(s"Listeners are not identical across brokers: $aliveNodes")`
	`545`	`+ info(s"Listeners are not identical across brokers: $aliveNodes")`
`546`	`546`	`}`
`547`	`547`
`548`	`548`	`val topicIds = mutable.Map.empty[String, Uuid]`