From 5812a0eef6cc2f18eaaddb1d74d809cfb0ff0ce0 Mon Sep 17 00:00:00 2001 From: Jarrod Johnson Date: Fri, 8 Jan 2021 16:15:11 -0500 Subject: [PATCH] Have a rebalance shortly after becoming leader This will handle startup and takeover when the current leader dies. --- confluent_server/confluent/collective/manager.py | 1 + 1 file changed, 1 insertion(+) diff --git a/confluent_server/confluent/collective/manager.py b/confluent_server/confluent/collective/manager.py index a0342d09..2f0bc938 100644 --- a/confluent_server/confluent/collective/manager.py +++ b/confluent_server/confluent/collective/manager.py @@ -569,6 +569,7 @@ def become_leader(connection): if dronecandidate in skipem or member == myname: continue eventlet.spawn_n(try_assimilate, dronecandidate) + schedule_rebalance() def startup():