Pritam Kumar created KAFKA-14220: ------------------------------------ Summary: "partition-count" not getting updated after revocation of partitions in case of Incremental Co-operative rebalancing. Key: KAFKA-14220 URL: https://issues.apache.org/jira/browse/KAFKA-14220 Project: Kafka Issue Type: Bug Components: KafkaConnect Affects Versions: 3.0.1 Reporter: Pritam Kumar
In case of the revocation of partitions, the updation of "partition count" metrics is being done before updating the new set of assignments. "{*}invokePartitionsRevoked{*}" method of "{*}onJoinComplete{*}" function of "{*}ConsumerCoordinator{*}" class is being called before the " {*}subscriptions.assignFromSubscribed(assignedPartitions){*}" of the same class. As a result of which the *old assigned partition count* is getting updated again and again even after future rebalances. -- This message was sent by Atlassian Jira (v8.20.10#820010)