From f301cd272f7f1a565965454ddd5cb7d4286ab592 Mon Sep 17 00:00:00 2001
From: Jarrod Johnson <jjohnson2@lenovo.com>
Date: Sun, 24 Jun 2018 11:08:15 -0400
Subject: [PATCH] Have follower notice lost leader

This will mitigate period during which requests
hang instead of error.
---
 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 c3d5c0de..d27c5e9b 100644
--- a/confluent_server/confluent/config/configmanager.py
+++ b/confluent_server/confluent/config/configmanager.py
@@ -510,6 +510,8 @@ def follow_channel(channel):
             if 'xid' in rpc and rpc['xid']:
                 _pendingchangesets[rpc['xid']].send()
         msg = channel.recv(8)
+    # mark the connection as broken
+    cfgleader = True
 
 def add_collective_member(name, address, fingerprint):
     try: