kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject [kafka] branch trunk updated (c06e45a -> d88f104)
Date Mon, 07 Oct 2019 16:27:25 GMT
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 c06e45a  KAFKA-8985; Add flexible version support to inter-broker APIs (#7453)
     add d88f104  KAFKA-8179: Part 7, cooperative rebalancing in Streams (#7386)

No new revisions were added by this update.

Summary of changes:
 checkstyle/suppressions.xml                        |   3 +
 .../consumer/internals/ConsumerCoordinator.java    |  20 +-
 .../consumer/internals/SubscriptionState.java      |  15 +-
 .../clients/consumer/internals/FetcherTest.java    |  31 +-
 .../processor/internals/AssignedStreamsTasks.java  |  15 +-
 .../streams/processor/internals/StandbyTask.java   |  19 -
 .../processor/internals/StoreChangelogReader.java  |  16 +-
 .../streams/processor/internals/StreamTask.java    |   8 +-
 .../streams/processor/internals/StreamThread.java  |  27 +-
 .../internals/StreamsPartitionAssignor.java        | 612 +++++++++++++++------
 .../kafka/streams/processor/internals/Task.java    |   8 +-
 .../streams/processor/internals/TaskManager.java   |  34 +-
 .../assignment/AssignorConfiguration.java          |  12 +-
 .../internals/assignment/ClientState.java          |  56 +-
 .../internals/assignment/StickyTaskAssignor.java   |   8 +-
 .../processor/internals/AbstractTaskTest.java      |   6 -
 .../processor/internals/StandbyTaskTest.java       |  23 -
 .../internals/StreamsPartitionAssignorTest.java    | 481 ++++++++++++++--
 .../processor/internals/TaskManagerTest.java       |  28 +-
 .../internals/assignment/ClientStateTest.java      |   8 +-
 .../assignment/StickyTaskAssignorTest.java         |  34 +-
 .../kafka/streams/tests/SmokeTestDriver.java       |   2 +-
 .../kafka/streams/tests/StreamsUpgradeTest.java    |  26 +-
 tests/kafkatest/tests/streams/streams_eos_test.py  |   2 +-
 24 files changed, 1058 insertions(+), 436 deletions(-)


Mime
View raw message