diff --git a/confluent_server/confluent/config/configmanager.py b/confluent_server/confluent/config/configmanager.py
index e147e4c6..5658d378 100644
--- a/confluent_server/confluent/config/configmanager.py
+++ b/confluent_server/confluent/config/configmanager.py
@@ -479,7 +479,7 @@ def relay_slaved_requests(name, listener):
         msg = listener.recv(8)
     listener.close()
     del cfgstreams[name]
-    if not cfgstreams:
+    if not cfgstreams and not cfgleader:
         cfgleader = True