showuon commented on code in PR #12748: URL: https://github.com/apache/kafka/pull/12748#discussion_r1034452624
########## clients/src/main/java/org/apache/kafka/clients/consumer/StickyAssignor.java: ########## @@ -216,6 +216,8 @@ public ByteBuffer subscriptionUserData(Set<String> topics) { @Override protected MemberData memberData(Subscription subscription) { + // Always deserialize ownedPartitions and generation id from user data + // since StickyAssignor is an eager rebalance protocol that will revoke all existing partitions before joining group Review Comment: In StickyAssignor, we still deserialize the user data to retrieve all the data since it is an eager rebalance protocol. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org