You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by rh...@apache.org on 2019/12/04 23:28:29 UTC
[kafka] branch trunk updated (91f9487 -> 0e57a39)
This is an automated email from the ASF dual-hosted git repository.
rhauch pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 91f9487 Actually run the delete topic command in kafka.py (#7776)
add 0e57a39 KAFKA-9184: Redundant task creation and periodic rebalances after zombie Connect worker rejoins the group (#7771)
No new revisions were added by this update.
Summary of changes:
.../runtime/distributed/DistributedHerder.java | 8 ++-
.../IncrementalCooperativeAssignor.java | 23 ++++++-
.../runtime/distributed/WorkerCoordinator.java | 72 ++++++++++++++------
.../runtime/distributed/WorkerGroupMember.java | 4 ++
.../integration/ConnectWorkerIntegrationTest.java | 78 ++++++++++++++++++++--
.../IncrementalCooperativeAssignorTest.java | 16 +++++
.../util/clusters/EmbeddedKafkaCluster.java | 50 +++++++++++---
7 files changed, 207 insertions(+), 44 deletions(-)