li xiangyuan created KAFKA-15170:
------------------------------------
Summary: CooperativeStickyAssignor cannot adjust assignment
correctly
Key: KAFKA-15170
URL: https://issues.apache.org/jira/browse/KAFKA-15170
Project: Kafka
Issue Type: Bug
Components: consumer
Affects Versions: 3.5.0
Reporter: li xiangyuan
Assignee: li xiangyuan
AbstractStickyAssignor use ConstrainedAssignmentBuilder to build assignment
when all consumers in group subscribe the same topic list, but it couldn't add
all partitions move owner to another consumer to
``partitionsWithMultiplePreviousOwners``.
the reason is in function assignOwnedPartitions hasn't add partitions that
rack-mismatch with prev owner to allRevokedPartitions, then partition only in
this list would add to partitionsWithMultiplePreviousOwners.
In Cooperative Rebalance, partitions have changed owner must be removed from
final assignment or will lead to incorrect consume behavior, I have already
raise a pr, please take a look, thx
https://github.com/apache/kafka/pull/13965
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
