You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Andrew Grant (Jira)" <ji...@apache.org> on 2023/01/08 15:09:00 UTC

[jira] [Updated] (KAFKA-14608) Make sure reassignment does not cause under min ISR

     [ https://issues.apache.org/jira/browse/KAFKA-14608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Andrew Grant updated KAFKA-14608:
---------------------------------
    Description: 
In KRaft mode we complete reassignments only when the adding replicas have been added to the ISR - see [https://github.com/apache/kafka/blob/trunk/metadata/src/main/java/org/apache/kafka/controller/PartitionChangeBuilder.java#L288.] As a result its possible for the partition to go under min ISR if the number of adding replicas is less than the topic's under min ISR config.

This behavior differs to ZK mode where we require all target replicas to be in the ISR for the reassignment to complete - see https://github.com/apache/kafka/blob/trunk/core/src/main/scala/kafka/controller/KafkaController.scala#L1003.

> Make sure reassignment does not cause under min ISR
> ---------------------------------------------------
>
>                 Key: KAFKA-14608
>                 URL: https://issues.apache.org/jira/browse/KAFKA-14608
>             Project: Kafka
>          Issue Type: Improvement
>            Reporter: Andrew Grant
>            Priority: Major
>
> In KRaft mode we complete reassignments only when the adding replicas have been added to the ISR - see [https://github.com/apache/kafka/blob/trunk/metadata/src/main/java/org/apache/kafka/controller/PartitionChangeBuilder.java#L288.] As a result its possible for the partition to go under min ISR if the number of adding replicas is less than the topic's under min ISR config.
> This behavior differs to ZK mode where we require all target replicas to be in the ISR for the reassignment to complete - see https://github.com/apache/kafka/blob/trunk/core/src/main/scala/kafka/controller/KafkaController.scala#L1003.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)