[
https://issues.apache.org/jira/browse/KAFKA-21266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eric Chang reassigned KAFKA-21266:
----------------------------------
Assignee: Eric Chang (was: Chia-Ping Tsai)
> getTopicEffectiveMinIsr should take the replicas from the target partition
> --------------------------------------------------------------------------
>
> Key: KAFKA-21266
> URL: https://issues.apache.org/jira/browse/KAFKA-21266
> Project: Kafka
> Issue Type: Bug
> Reporter: Chia-Ping Tsai
> Assignee: Eric Chang
> Priority: Major
>
> {code:java}
> int getTopicEffectiveMinIsr(String topicName) {
> String minIsrConfig = configurationControl.getTopicConfig(topicName,
> MIN_IN_SYNC_REPLICAS_CONFIG).value();
> int currentMinIsr = Integer.parseInt(minIsrConfig);
> Uuid topicId = topicsByName.get(topicName);
> int replicationFactor =
> topics.get(topicId).parts.get(0).replicas.length;
> return Math.min(currentMinIsr, replicationFactor);
> } {code}
> Since each partition is allowed to have different replicas, the incorrect
> replica number could clear the ELR unexpectedly. For example, the first
> partition has only 1 replica, so the controller assumes the HW can be
> advanced (due to min ISR = 1) and clears the ELR set.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
