Details
-
Bug
-
Status: Resolved
-
Minor
-
Resolution: Fixed
-
None
-
None
-
None
Description
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.
Attachments
Issue Links
- links to