diff --git a/core/src/main/scala/kafka/server/KafkaConfig.scala b/core/src/main/scala/kafka/server/KafkaConfig.scala index 1bce2eaf4c0b2..9e45dfcc3fabf 100755 --- 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