Versions Compared

Key

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

...

(2) Get topic-level configuration (from `KafkaZkClient.getLogConfigs` and while passing in default "min.insync.replicas" as the value retrieved from (1))

We must pass the default value as a parameter in (2) as `getLogConfigs` will return a default value if the specified configuration is not specifically 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` will return the default value so we must make sure it has the value used by the broker/cluster.

...