[ 
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)

Reply via email to