You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Pritam Kumar (Jira)" <ji...@apache.org> on 2022/09/12 11:55:00 UTC

[jira] [Commented] (KAFKA-14220) "partition-count" not getting updated after revocation of partitions in case of Incremental Co-operative rebalancing.

    [ https://issues.apache.org/jira/browse/KAFKA-14220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17603056#comment-17603056 ] 

Pritam Kumar commented on KAFKA-14220:
--------------------------------------

The following is the patch made and verified:
*https://github.com/apache/kafka/pull/12622*

> "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
>            Priority: Major
>
> 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)