From c49b2fd8abeb66c9bf16a45c4fad1acddf00b463 Mon Sep 17 00:00:00 2001 From: Jarrod Johnson Date: Tue, 7 Apr 2026 14:57:09 -0400 Subject: [PATCH] Update quorum on deletion If deletion of a node brings quorum, notify followers of the good news --- confluent_server/confluent/config/configmanager.py | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/confluent_server/confluent/config/configmanager.py b/confluent_server/confluent/config/configmanager.py index 10eff81c..2112ed7f 100644 --- a/confluent_server/confluent/config/configmanager.py +++ b/confluent_server/confluent/config/configmanager.py @@ -1013,6 +1013,14 @@ def del_collective_member(name): if cfgstreams: exec_on_followers_unconditional('_true_del_collective_member', name) _true_del_collective_member(name) + if cfgstreams: + _hasquorum = has_quorum() + pushes = eventlet.GreenPool() + payload = msgpack.packb({'quorum': _hasquorum}, use_bin_type=False) + for _ in pushes.starmap( + _push_rpc, + [(cfgstreams[s]['stream'], payload) for s in cfgstreams]): + pass def _true_del_collective_member(name, sync=True): global cfgleader