From 4d9b11bc5593f99f258c0f73d5417ffc1e717bf1 Mon Sep 17 00:00:00 2001 From: Jarrod Johnson Date: Mon, 6 Mar 2023 16:38:09 -0500 Subject: [PATCH] Fix quorum when there is no collective yet --- confluent_server/confluent/config/configmanager.py | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/confluent_server/confluent/config/configmanager.py b/confluent_server/confluent/config/configmanager.py index 46984055..6c773d0a 100644 --- a/confluent_server/confluent/config/configmanager.py +++ b/confluent_server/confluent/config/configmanager.py @@ -638,6 +638,10 @@ def has_quorum(): for follower in cfgstreams: if cfgstreams[follower].get('role', None) != 'nonvoting': voters += 1 + iam = get_collective_member(get_myname()) + myrole = None + if iam: + myrole = iam.get('role', None) myrole = get_collective_member(get_myname()).get('role', None) if myrole != 'nonvoting': voters += 1