Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

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

...