...
Current state: Under Discussion
Discussion thread: here
JIRA: KAFKA-7236
Please keep the discussion on the mailing list rather than commenting on the wiki (wiki discussions get unwieldy fast).
...
We must pass the default value as a parameter in (2) as `getLogConfigs` `KafkaZkClient.getLogConfigs` will return a default value if the specified configuration is not set in Zookeeper (Kafka default for "min.insync.replicas" is 1).
If the user has configured "min.insync.replicas" on the broker/cluster-level (and not topic-level), then `getLogConfigs` `KafkaZkClient.getLogConfigs` will return the default value of 1 instead of the broker/cluster-level value, so we must make sure it has to pass in the value used by the broker/cluster as the "default" value.
This means we must add an additional flag "--bootstrap-server" to use AdminClient to get the broker/cluster "min.insync.replicas" configuration to use as the default when it is not found in Zookeeper.
Example of using the command:
Code Block |
---|
bin/kafka-topics.sh --zookeeper localhost:2181 --describe --under-min-isr-partitions --bootstrap-server localhost:9092 |
Compatibility, Deprecation, and Migration Plan
...