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