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