Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-15170

CooperativeStickyAssignor cannot adjust assignment correctly

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • 3.5.0
    • 3.8.0, 3.7.1
    • consumer
    • None

    Description

      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

      Attachments

        Issue Links

          Activity

            People

              flashmouse li xiangyuan
              flashmouse li xiangyuan
              Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: