This is an automated email from the ASF dual-hosted git repository.
guozhang pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from e23a718 KAFKA-8745: DumpLogSegments doesn't show keys, when the
message is null (#7152)
add cf32a1a KAFKA-8179: Part 4, add CooperativeStickyAssignor (#7130)
No new revisions were added by this update.
Summary of changes:
.../consumer/CooperativeStickyAssignor.java | 105 +++
.../kafka/clients/consumer/StickyAssignor.java | 885 +--------------------
.../AbstractStickyAssignor.java} | 331 ++------
.../consumer/internals/PartitionAssignor.java | 5 +-
.../internals/PartitionAssignorAdapter.java | 6 +-
.../consumer/CooperativeStickyAssignorTest.java | 105 +++
.../kafka/clients/consumer/StickyAssignorTest.java | 868 ++------------------
.../AbstractStickyAssignorTest.java} | 513 ++++--------
docs/upgrade.html | 8 +-
.../streams/integration/EosIntegrationTest.java | 2 +-
10 files changed, 513 insertions(+), 2315 deletions(-)
create mode 100644
clients/src/main/java/org/apache/kafka/clients/consumer/CooperativeStickyAssignor.java
copy
clients/src/main/java/org/apache/kafka/clients/consumer/{StickyAssignor.java =>
internals/AbstractStickyAssignor.java} (75%)
create mode 100644
clients/src/test/java/org/apache/kafka/clients/consumer/CooperativeStickyAssignorTest.java
copy
clients/src/test/java/org/apache/kafka/clients/consumer/{StickyAssignorTest.java
=> internals/AbstractStickyAssignorTest.java} (57%)
