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 (dc7dd5f -> 8da6993)
Date Wed, 02 Oct 2019 15:54:50 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 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(-)


Mime
View raw message