From 3eed46ec08ca6a4ccef9da236a7f06ce9b6fde60 Mon Sep 17 00:00:00 2001 From: Jarrod Johnson Date: Sat, 2 Jun 2018 12:36:20 -0400 Subject: [PATCH] Disconnect on loss of ownership --- confluent_server/confluent/consoleserver.py | 1 + 1 file changed, 1 insertion(+) diff --git a/confluent_server/confluent/consoleserver.py b/confluent_server/confluent/consoleserver.py index 09e32756..7792d275 100644 --- a/confluent_server/confluent/consoleserver.py +++ b/confluent_server/confluent/consoleserver.py @@ -237,6 +237,7 @@ class ConsoleHandler(object): # Do not do console connect for nodes managed by another # confluent collective member self._is_local = False + self._disconnect() else: self._is_local = True