2
0
mirror of https://github.com/xcat2/confluent.git synced 2024-11-22 17:43:14 +00:00

Have follower notice lost leader

This will mitigate period during which requests
hang instead of error.
This commit is contained in:
Jarrod Johnson 2018-06-24 11:08:15 -04:00
parent bf4f5ad5ae
commit f301cd272f

View File

@ -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: