diff --git a/confluent_server/confluent/collective/manager.py b/confluent_server/confluent/collective/manager.py
index c681e3bd..87477241 100644
--- a/confluent_server/confluent/collective/manager.py
+++ b/confluent_server/confluent/collective/manager.py
@@ -90,6 +90,7 @@ def connect_to_leader(cert=None, name=None, leader=None):
                 raise Exception(keydata['error'])
             if follower is not None:
                 follower.kill()
+                cfm.stop_following()
                 follower = None
             colldata = tlvdata.recv(remote)
             globaldata = tlvdata.recv(remote)