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 778b1e3 KAFKA-9835; Protect `FileRecords.slice` from concurrent write
(#8451)
add ed3a715 KAFKA-6145: KIP-441 Move tasks with caught-up destination
clients right away (#8425)
No new revisions were added by this update.
Summary of changes:
.../internals/StreamsPartitionAssignor.java | 8 +-
.../DefaultStateConstrainedBalancedAssignor.java | 44 ++---
.../assignment/HighAvailabilityTaskAssignor.java | 7 +-
.../internals/assignment/RankedClient.java | 23 +++
.../StateConstrainedBalancedAssignor.java | 3 +-
.../internals/assignment/TaskMovement.java | 37 +++-
.../internals/StreamsPartitionAssignorTest.java | 14 +-
...efaultStateConstrainedBalancedAssignorTest.java | 205 ++++++++++++++-------
.../internals/assignment/RankedClientTest.java | 33 ++++
.../internals/assignment/TaskMovementTest.java | 128 ++++++++++---
10 files changed, 362 insertions(+), 140 deletions(-)
