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 dc7dd5f MINOR: Do not falsely log that partitions are being reassigned on controller startup (#7431) add 8da6993 KAFKA-8649: Send latest commonly supported version in assignment (#7423) No new revisions were added by this update. Summary of changes: .../internals/StreamsPartitionAssignor.java | 216 +++++++++++++-------- .../internals/StreamsRebalanceListener.java | 4 +- .../streams/processor/internals/TaskManager.java | 8 +- .../internals/assignment/AssignmentInfo.java | 60 +++--- .../internals/assignment/ClientState.java | 36 +++- .../internals/StreamsPartitionAssignorTest.java | 2 +- .../processor/internals/TaskManagerTest.java | 1 + .../internals/assignment/ClientStateTest.java | 4 +- .../assignment/StickyTaskAssignorTest.java | 34 ++-- .../kafka/streams/tests/StreamsUpgradeTest.java | 7 + .../tests/streams/streams_upgrade_test.py | 27 +-- 11 files changed, 241 insertions(+), 158 deletions(-)