From 4b6899d4af3819416ca62dc281296a8dfd68ad5d Mon Sep 17 00:00:00 2001 From: Jarrod Johnson Date: Mon, 4 Nov 2019 13:43:29 -0500 Subject: [PATCH] Mark node as 'dirty' if it's group is removed Group removal would end up with the on-disk copy not reflecting the node membership, even though in-memory copy is fine. Fix by adding the missing dirty mark to the entry. --- confluent_server/confluent/config/configmanager.py | 1 + 1 file changed, 1 insertion(+) diff --git a/confluent_server/confluent/config/configmanager.py b/confluent_server/confluent/config/configmanager.py index f73dcc53..d258f981 100644 --- a/confluent_server/confluent/config/configmanager.py +++ b/confluent_server/confluent/config/configmanager.py @@ -1628,6 +1628,7 @@ class ConfigManager(object): if group in self._cfgstore['nodes'][node]['groups']: self._cfgstore['nodes'][node]['groups'].remove(group) self._node_removed_from_group(node, group, changeset) + _mark_dirtykey('nodes', node, self.tenant) for node in nodes: if node not in self._cfgstore['nodes']: self._cfgstore['nodes'][node] = {'groups': [group]}