mirror of
https://github.com/xcat2/confluent.git
synced 2025-07-15 17:16:11 +00:00
Fix missing tenant argument on user management function
The tenant was omitted preventing those particular rpc calls from working correctly.
This commit is contained in:
@ -1232,9 +1232,9 @@ class ConfigManager(object):
|
||||
|
||||
def del_user(self, name):
|
||||
if cfgleader:
|
||||
return exec_on_leader('_rpc_master_del_user', name)
|
||||
return exec_on_leader('_rpc_master_del_user', self.tenant, name)
|
||||
if cfgstreams:
|
||||
exec_on_followers('_rpc_del_user', name)
|
||||
exec_on_followers('_rpc_del_user', self.tenant, name)
|
||||
self._true_del_user(name)
|
||||
|
||||
def _true_del_user(self, name):
|
||||
|
Reference in New Issue
Block a user