-
Type:
Bug
-
Status: Resolved
-
Priority:
Minor
-
Resolution: Fixed
-
Affects Version/s: None
-
Fix Version/s: 2.7.0
-
Component/s: None
-
Labels:None
def immutableListenerConfigs(kafkaConfig: KafkaConfig, prefix: String): Map[String, AnyRef] = { newConfig.originals.asScala.filter { case (key, _) => key.startsWith(prefix) && !DynamicSecurityConfigs.contains(key) } }
We don't actually compare new configs to origin configs so the suitable exception is not thrown.
- links to