[
https://issues.apache.org/jira/browse/KAFKA-12654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen updated KAFKA-12654:
------------------------------
Description: 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 don't need to deserialize data for
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. (was: 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.)
> 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
> Priority: Major
>
> 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 don't need to deserialize data for 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)
