kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From vvcep...@apache.org
Subject [kafka] branch trunk updated (f0ad030 -> 2322bc0)
Date Thu, 02 Apr 2020 18:36:32 GMT
This is an automated email from the ASF dual-hosted git repository.

vvcephei pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.


    from f0ad030  MINOR: System test ZooKeeper upgrades (#8384)
     add 2322bc0  KAFKA-6145: Pt. 5 Implement high availability assignment (#8337)

No new revisions were added by this update.

Summary of changes:
 checkstyle/suppressions.xml                        |   4 +-
 .../org/apache/kafka/streams/StreamsConfig.java    |   2 +-
 .../internals/StreamsPartitionAssignor.java        | 138 +---
 .../assignment/AssignorConfiguration.java          |  42 +-
 .../internals/assignment/ClientState.java          |  72 +-
 .../DefaultStateConstrainedBalancedAssignor.java   |  44 +-
 .../assignment/HighAvailabilityTaskAssignor.java   | 551 ++++++++++++++
 .../StateConstrainedBalancedAssignor.java          |  36 +-
 .../internals/assignment/StickyTaskAssignor.java   |  24 +-
 .../internals/assignment/TaskAssignor.java         |   7 +-
 .../internals/StreamsPartitionAssignorTest.java    | 241 ++-----
 .../internals/assignment/ClientStateTest.java      |  10 +-
 ...efaultStateConstrainedBalancedAssignorTest.java | 132 ++--
 .../HighAvailabilityTaskAssignorTest.java          | 796 +++++++++++++++++++++
 .../assignment/StickyTaskAssignorTest.java         | 120 ++--
 15 files changed, 1706 insertions(+), 513 deletions(-)
 create mode 100644 streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/HighAvailabilityTaskAssignor.java
 create mode 100644 streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/HighAvailabilityTaskAssignorTest.java


Mime
View raw message