From 46fc4d626d4362826aa751d51ad6a208636a3875 Mon Sep 17 00:00:00 2001 From: Jarrod Johnson Date: Wed, 26 Aug 2020 13:35:19 -0400 Subject: [PATCH] Fix quorum check in configmanager.py --- confluent_server/confluent/config/configmanager.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/confluent_server/confluent/config/configmanager.py b/confluent_server/confluent/config/configmanager.py index 495c242a..1313395d 100644 --- a/confluent_server/confluent/config/configmanager.py +++ b/confluent_server/confluent/config/configmanager.py @@ -311,7 +311,7 @@ def _rpc_set_group_attributes(tenant, attribmap, autocreate): def check_quorum(): if isinstance(cfgleader, bool): raise exc.DegradedCollective() - if cfgstreams and len(cfgstreams) < (len(_cfgstore['collective']) // 2): + if (not cfgleader) and len(cfgstreams) < (len(_cfgstore['collective']) // 2): # the leader counts in addition to registered streams raise exc.DegradedCollective() if cfgleader and not _hasquorum: