This is an automated email from the ASF dual-hosted git repository.
ableegoldman pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from b80ff18 KAFKA-12554: Refactor Log layer (#10280)
add 37d086f KAFKA-12984: make AbstractStickyAssignor resilient to invalid
input, utilize generation in cooperative, and fix assignment bug (#10985)
No new revisions were added by this update.
Summary of changes:
checkstyle/suppressions.xml | 2 +-
.../consumer/CooperativeStickyAssignor.java | 42 +++++-
.../consumer/internals/AbstractStickyAssignor.java | 167 +++++++++++++--------
.../consumer/CooperativeStickyAssignorTest.java | 87 ++++++++++-
.../kafka/clients/consumer/StickyAssignorTest.java | 49 +++++-
.../internals/AbstractStickyAssignorTest.java | 74 ++++++++-
6 files changed, 341 insertions(+), 80 deletions(-)
