This is an automated email from the ASF dual-hosted git repository.
guozhang pushed a change to branch 2.5
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 8194c86 KAFKA-10056; Ensure consumer metadata contains new topics on subscription
change (#8739)
add 5842d2f KAFKA-9987: optimize sticky assignment algorithm for same-subscription case
(#8668)
No new revisions were added by this update.
Summary of changes:
checkstyle/suppressions.xml | 4 +-
.../consumer/CooperativeStickyAssignor.java | 46 +--
.../consumer/internals/AbstractStickyAssignor.java | 319 ++++++++++++++-------
.../kafka/clients/consumer/StickyAssignorTest.java | 5 +-
.../internals/AbstractStickyAssignorTest.java | 82 +++---
5 files changed, 283 insertions(+), 173 deletions(-)
|