You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Luke Chen (Jira)" <ji...@apache.org> on 2021/04/12 06:26:00 UTC

[jira] [Created] (KAFKA-12654) separate checkAllSubscriptionEqual and getConsumerToOwnedPartitions methods

Luke Chen created KAFKA-12654:
---------------------------------

             Summary: separate checkAllSubscriptionEqual and getConsumerToOwnedPartitions methods
                 Key: KAFKA-12654
                 URL: https://issues.apache.org/jira/browse/KAFKA-12654
             Project: Kafka
          Issue Type: Improvement
            Reporter: Luke Chen
            Assignee: Luke Chen


Currently, when entering sticky assignor, we'll check if all consumers have the same subscription to decide which assignor to use (constrained assignor or general assignor). While checking the subscription, we also deserialize the subscription user data to get the partitions owned by the consumer (consumerToOwnedPartitions). However, the consumerToOwnedPartitions info is not used in general assignor. We should separate these 2 things into 2 methods, and only deserialize the user data for constrained assignor, to improve the general sticky assignor performance.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)