diff --git a/confluent_server/confluent/collective/manager.py b/confluent_server/confluent/collective/manager.py index 4194966e..c45cb9b5 100644 --- a/confluent_server/confluent/collective/manager.py +++ b/confluent_server/confluent/collective/manager.py @@ -87,7 +87,8 @@ def connect_to_leader(cert=None, name=None, leader=None): leader=keydata['leader']) if 'txcount' in keydata: return become_leader(remote) - raise Exception(keydata['error']) + print(keydata['error']) + return False if follower is not None: follower.kill() cfm.stop_following()