From a905ae48658774d5d4ac7cd7bd9da32644fb8980 Mon Sep 17 00:00:00 2001 From: Jarrod Johnson Date: Tue, 3 Jul 2018 14:43:23 -0400 Subject: [PATCH] Only zap cfgleader if not set stale relay_slaved_requests was trouncing following status, correct by avoiding zapping that state --- 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 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