New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
KAFKA-16277: AbstractStickyAssignor - Sort owned TopicPartitions by partition when reassigning #15416
Conversation
…artition when reassigning
6632174
to
cc2bbfa
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks for the PR! One more small suggestion: it would be great if you could write a short test case that covers the exact scenario you described in the ticket. That way we can be completely sure the fix works as intended, and hopefully prevent any future issues that break this case
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java
Outdated
Show resolved
Hide resolved
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java
Show resolved
Hide resolved
…als/AbstractStickyAssignor.java Co-authored-by: A. Sophie Blee-Goldman <ableegoldman@gmail.com>
Thanks for the review @ableegoldman - I have incorporated your suggested changes |
d35079a
to
3dc1770
Compare
I was going to try to fix the pipeline issue:
But then I saw it had been attempted and reverted 😭 #15292 |
Test failures are unrelated, merged to trunk. Thanks for the fix! |
…artition when reassigning (apache#15416) Treats KAFKA-16277 - CooperativeStickyAssignor does not spread topics evenly among consumer group Reviewers: Anna Sophie Blee-Goldman <ableegoldman@apache.org>
…artition when reassigning (apache#15416) Treats KAFKA-16277 - CooperativeStickyAssignor does not spread topics evenly among consumer group Reviewers: Anna Sophie Blee-Goldman <ableegoldman@apache.org>
…artition when reassigning (#15416) Treats KAFKA-16277 - CooperativeStickyAssignor does not spread topics evenly among consumer group Reviewers: Anna Sophie Blee-Goldman <ableegoldman@apache.org>
FYI I cherrypicked this back to 3.7 while cherrypicking back another sticky assignor fix. Should be in the 3.7.1 release |
Context
Treats
KAFKA-16277 - CooperativeStickyAssignor does not spread topics evenly among consumer group
https://issues.apache.org/jira/browse/KAFKA-16277
@ableegoldman :
Test strategy:
topic1
, they are spread across multiple consumers.Changes
Committer Checklist (excluded from commit message)