You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@kafka.apache.org by gu...@apache.org on 2019/08/27 21:41:51 UTC

[kafka] branch trunk updated (e23a718 -> cf32a1a)

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%)