diff --git a/confluent_server/confluent/consoleserver.py b/confluent_server/confluent/consoleserver.py index 792ef4b2..639cf466 100644 --- a/confluent_server/confluent/consoleserver.py +++ b/confluent_server/confluent/consoleserver.py @@ -237,6 +237,8 @@ class ConsoleHandler(object): # Do not do console connect for nodes managed by another # confluent collective member self._is_local = False + else: + self._is_local = True def get_buffer_age(self): """Return age of buffered data