This is an automated email from the ASF dual-hosted git repository.
kkarantasis pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 1711cfa KAFKA-12209: Add the timeline data structures for the KIP-631
controller (#9901)
add e260f64 KAFKA-10413: Allow for even distribution of lost/new tasks
when multiple Connect workers join at the same time (#9319)
No new revisions were added by this update.
Summary of changes:
.../IncrementalCooperativeAssignor.java | 54 ++++++++++------
.../RebalanceSourceConnectorsIntegrationTest.java | 71 ++++++++++++++++++++--
.../IncrementalCooperativeAssignorTest.java | 24 +++++---
.../WorkerCoordinatorIncrementalTest.java | 19 +++---
4 files changed, 127 insertions(+), 41 deletions(-)
