KAFKA-13600: Kafka Streams - Fall back to most caught up client if no caught up clients exist#11760

Merged

cadonna merged 10 commits into

apache:trunkfrom

tim-patterson:KAFKA-13600-2

Mar 28, 2022

Commits on Feb 14, 2022

[KAFKA-13600] Unit test to capture not assigning to caught up task if all other replicas are behind
tim-patterson
committed

Commits on Feb 15, 2022

[KAFKA-13600] Fall back to most caught up client if a caught up client can't be found
tim-patterson
committed

Commits on Feb 16, 2022

[KAFKA-13600] Fix copy paste mistake
tim-patterson
committed

Commits on Feb 18, 2022

[KAFKA-13600] Make all cases for active assignment more explicit
tim-patterson
committed

Commits on Feb 28, 2022

[KAFKA-13600] Use SortedSet for clients in tasksToClientByLag
tim-patterson
committed

Commits on Mar 11, 2022

Commits on Mar 14, 2022

[KAFKA-13600] break up large method
tim-patterson
committed

Commits on Mar 25, 2022

Update streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/TaskMovement.java

tim-patterson
and
cadonna
authored

Commits on Mar 28, 2022

[KAFKA-13600] Add taskmovement test for moving active to most caught up
tim-patterson
committed