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