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

Posted to commits@kafka.apache.org by kk...@apache.org on 2021/02/02 20:05:41 UTC

[kafka] branch trunk updated (1711cfa -> e260f64)

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