2
0
mirror of https://github.com/xcat2/confluent.git synced 2024-12-25 12:41:39 +00:00

Fix missing argument to rpc_set_user

Requests were unable to traverse
a collective.
This commit is contained in:
Jarrod Johnson 2020-02-05 14:55:51 -05:00
parent 1aee19997a
commit 201985dd0e

View File

@ -1405,7 +1405,7 @@ class ConfigManager(object):
return exec_on_leader('_rpc_master_set_user', self.tenant, name,
attributemap)
if cfgstreams:
exec_on_followers('_rpc_set_user', self.tenant, name)
exec_on_followers('_rpc_set_user', self.tenant, name, attributemap)
self._true_set_user(name, attributemap)
def _true_set_user(self, name, attributemap):