From 1d16534c16793df34ddc9fc59af477a9b02fdca3 Mon Sep 17 00:00:00 2001
From: Jarrod Johnson <jjohnson2@lenovo.com>
Date: Fri, 13 Jul 2018 09:37:00 -0400
Subject: [PATCH] If replacing a follower stream, ensure the old one closes

---
 confluent_server/confluent/config/configmanager.py | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/confluent_server/confluent/config/configmanager.py b/confluent_server/confluent/config/configmanager.py
index a6c7a865..ddd06360 100644
--- a/confluent_server/confluent/config/configmanager.py
+++ b/confluent_server/confluent/config/configmanager.py
@@ -463,6 +463,8 @@ cfgstreams = {}
 def relay_slaved_requests(name, listener):
     global cfgleader
     stop_following()
+    if name in cfgstreams:
+        cfgstreams[name].close()
     cfgstreams[name] = listener
     msg = listener.recv(8)
     while msg: