KAFKA-18886: Log warnings only if the policy is explicitly defined.

apache · Mar 4, 2025 · b93d475 · b93d475
1 parent d75cc10
commit b93d475
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/core/src/main/scala/kafka/server/KafkaConfig.scala b/core/src/main/scala/kafka/server/KafkaConfig.scala
@@ -666,7 +666,9 @@ class KafkaConfig private(doLog: Boolean, val props: util.Map[_, _])
           if (processRoles.contains(ProcessRole.BrokerRole)) s" Perhaps all listeners appear in ${KRaftConfigs.CONTROLLER_LISTENER_NAMES_CONFIG}?" else ""))
     }
     def warnIfConfigDefinedInWrongRole(expectedRole: ProcessRole, configName: String): Unit = {
-      warn(s"$configName is defined in ${processRoles.mkString(", ")}. It should be defined in the $expectedRole role.")
+      if (originals.containsKey(configName)) {
+        warn(s"$configName is defined in ${processRoles.mkString(", ")}. It should be defined in the $expectedRole role.")
+      }
     }
     if (processRoles == Set(ProcessRole.BrokerRole)) {
       // KRaft broker-only