Chia-Ping Tsai created KAFKA-21013:
--------------------------------------
Summary: Unable to dynamically update
group.*.assignment.interval.ms configs with config providers
Key: KAFKA-21013
URL: https://issues.apache.org/jira/browse/KAFKA-21013
Project: Kafka
Issue Type: Sub-task
Reporter: Chia-Ping Tsai
Assignee: Chia-Ping Tsai
{code:java}
// The 2-arg AbstractConfig ctor used for clamping enforces
org.apache.kafka.automatic.config.providers.
// That allowlist is meant to gate providers supplied via dynamic config
changes, not ones already
// declared in server.properties, which are trusted regardless of it.
Without this exclusion, a
// statically-declared provider plus a restrictive allowlist would reject
every dynamic config
// update below, not just provider-related ones.
val propsForClamping = new java.util.HashMap[String,
String](newProps.asJava)
propsForClamping.keySet().removeIf(k => k.startsWith("config.providers"))
KafkaConfig.clampDynamicConfigs(propsForClamping)
propsForClamping.forEach((k, v) => newProps(k) = v){code}
see the above comments
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
