KAFKA-9184: Redundant task creation and periodic rebalances after zombie Connect worker rejoins the group - #7771

Merged

rhauch merged 12 commits into

apache:trunkfrom

kkonstantine:kafka-9184

Dec 4, 2019

Commits on Dec 4, 2019

KAFKA-9184: Add a lightweight method to confirm connection to the broker coordinator is up from WorkerGroupMember
kkonstantine
committed
KAFKA-9184: Check connectivity with broker coordinator in intervals and stop tasks if coordinator is unreachable
kkonstantine
committed
KAFKA-9184: Reset rebalance delay when there are no lost tasks
kkonstantine
committed
KAFKA-9184: Remove unused import
kkonstantine
committed
KAFKA-9184: Set assignmentSnapshot to null after stopping tasks
kkonstantine
committed
KAFKA-9184: Extend embedded kafka cluster to allow restarts and add integration test
kkonstantine
committed
KAFKA-9184: Fix checkstyle
kkonstantine
committed
KAFKA-9184: Remove unused method
kkonstantine
committed
KAFKA-9184: Adapt unit test to the additional debug calls
kkonstantine
committed
KAFKA-9184: Add more specific logs to DistributedHerder
kkonstantine
committed
KAFKA-9184: Declare assignmentSnapshot volatile and use local copies of the reference
kkonstantine
committed
KAFKA-9184: Add some more time between phases in the integration test
kkonstantine
committed