From 24a3cbc133c8f8ce758e7d7bdf4742fa494be1ca Mon Sep 17 00:00:00 2001 From: Jarrod Johnson Date: Wed, 26 Aug 2020 13:54:18 -0400 Subject: [PATCH] Fix non-collective quorum check --- 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 1313395d..d83cd4be 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 (not cfgleader) and len(cfgstreams) < (len(_cfgstore['collective']) // 2): + if (not cfgleader) and len(cfgstreams) < (len(_cfgstore.get('collective', {})) // 2): # the leader counts in addition to registered streams raise exc.DegradedCollective() if cfgleader and not _hasquorum: