Pritam Kumar created KAFKA-15680:
------------------------------------
Summary: Partition-Count is not getting updated Correctly in the
Incremental Co-operative Rebalancing(ICR) Mode of Rebalancing
Key: KAFKA-15680
URL: https://issues.apache.org/jira/browse/KAFKA-15680
Project: Kafka
Issue Type: Bug
Components: connect
Affects Versions: 3.0.1
Reporter: Pritam Kumar
Assignee: Pritam Kumar
* In ICR(Incremental Cooperative Rebalancing) mode, whenever a new worker, say
Worker 3 joins, a new global assignment is computed by the leader, say Worker1,
that results in the revocation of some tasks from each existing worker i.e
Worker1 and Worker2.
* Once the new member join is completed,
*ConsumerCoordinator.OnJoinComplete()* method is called which primarily
computes all the new partitions assigned and the partitions which are revoked
and updates the subscription Object.
* If it was the case of revocation which we check by checking the
“partitonsRevoked” list, we call the method {*}“invoke{*}PartitionRevoked()”
which internally calls “updatePartitionCount()” which fetches partition from
the *assignment* object which is yet not updated by the new assignment.
* It is only just before calling the “{*}invokePartitionsAssigned{*}()” method
that we update the *assignment* by invoking the following →
*subscriptions.assignFromSubscribed(assignedPartitions);*
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
