You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@kafka.apache.org by ca...@apache.org on 2022/03/28 14:51:40 UTC

[kafka] branch trunk updated (ca3271e -> 110bcca)

This is an automated email from the ASF dual-hosted git repository.

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


    from ca3271e  MINOR: replace kafka-preferred-replica-election.sh with kafka-leader-election.sh (#11954)
     add 110bcca  KAFKA-13600: Kafka Streams - Fall back to most caught up client if no caught up clients exist (#11760)

No new revisions were added by this update.

Summary of changes:
 .../assignment/HighAvailabilityTaskAssignor.java   |  17 ++
 .../internals/assignment/TaskMovement.java         | 178 +++++++++++++++------
 .../HighAvailabilityTaskAssignorTest.java          |  31 ++++
 .../internals/assignment/TaskMovementTest.java     | 144 ++++++++++++++---
 4 files changed, 303 insertions(+), 67 deletions(-)