2
0
mirror of https://github.com/xcat2/confluent.git synced 2024-11-27 03:49:57 +00:00

Have collective start bail out if leader

Leader should not relinquish if quorum, so don't bother in such
a case.
This commit is contained in:
Jarrod Johnson 2018-10-01 15:50:31 -04:00
parent 9495a41f85
commit c13ebe36ae

View File

@ -535,6 +535,12 @@ def start_collective():
if follower:
follower.kill()
follower = None
try:
if cfm.cfgstreams and cfm.check_quorum():
# Do not start if we have quorum and are leader
return
except exc.DegradedCollective:
pass
if leader_init.active: # do not start trying to connect if we are
# xmitting data to a follower
return