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

Posted to commits@kafka.apache.org by mj...@apache.org on 2018/05/31 05:39:49 UTC

[kafka] branch trunk updated (3683d47 -> d166485)

This is an automated email from the ASF dual-hosted git repository.

mjsax pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.


    from 3683d47  MINOR: Follow-up improvements for KIP-266 (#5084)
     add d166485  KAFKA-6054: Add 'version probing' to Kafka Streams rebalance (#4636)

No new revisions were added by this update.

Summary of changes:
 .../org/apache/kafka/streams/StreamsConfig.java    | 108 +++++-
 .../streams/processor/internals/AssignedTasks.java |  28 +-
 .../streams/processor/internals/StreamThread.java  |  36 +-
 .../internals/StreamsPartitionAssignor.java        | 229 +++++++++---
 .../streams/processor/internals/TaskManager.java   |  18 +-
 .../internals/assignment/AssignmentInfo.java       |  12 +-
 .../internals/assignment/ClientState.java          |  32 +-
 .../internals/assignment/SubscriptionInfo.java     |  65 ++--
 .../processor/internals/StreamThreadTest.java      |  27 +-
 .../internals/StreamsPartitionAssignorTest.java    | 393 ++++++++++++++-------
 .../internals/assignment/SubscriptionInfoTest.java |  16 +
 .../kafka/streams/tests/StreamsSmokeTest.java      |   2 +-
 .../kafka/streams/tests/StreamsUpgradeTest.java    | 284 ++++++++++++++-
 tests/kafkatest/services/streams.py                |  44 ++-
 .../tests/streams/streams_upgrade_test.py          | 207 ++++++++++-
 tests/kafkatest/version.py                         |   2 +-
 16 files changed, 1219 insertions(+), 284 deletions(-)

-- 
To stop receiving notification emails like this one, please contact
mjsax@apache.org.