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