2
0
mirror of https://github.com/xcat2/confluent.git synced 2025-01-15 20:27:50 +00:00

Correct another typo

This commit is contained in:
Jarrod Johnson 2018-05-23 13:02:03 -04:00
parent 8807fcfd22
commit 46c4065b81

View File

@ -1432,7 +1432,7 @@ class ConfigManager(object):
def del_nodes(self, nodes):
if cfgleader: # slaved to a collective
return exec_on_loader('_rpc_master_del_nodes', self.tenant,
return exec_on_leader('_rpc_master_del_nodes', self.tenant,
nodes)
if cfgstreams:
exec_on_followers('_rpc_del_nodes', self.tenant, nodes)