From 39378170b1cc230110cc496ac61b0f77e534a394 Mon Sep 17 00:00:00 2001
From: Jarrod Johnson <jjohnson2@lenovo.com>
Date: Tue, 3 Jul 2018 11:13:23 -0400
Subject: [PATCH] Add an error if cfgstreams loses a follower

---
 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 47f58880..e147e4c6 100644
--- a/confluent_server/confluent/config/configmanager.py
+++ b/confluent_server/confluent/config/configmanager.py
@@ -462,6 +462,8 @@ def relay_slaved_requests(name, listener):
     cfgstreams[name] = listener
     msg = listener.recv(8)
     while msg:
+        if name not in cfgstreams:
+            raise Exception("Unexpected loss of node in followers: " + name)
         sz = struct.unpack('!Q', msg)[0]
         if sz != 0:
             rpc = ''