From 201985dd0e725580da91372fd185e6f7f67f0a1f Mon Sep 17 00:00:00 2001 From: Jarrod Johnson Date: Wed, 5 Feb 2020 14:55:51 -0500 Subject: [PATCH] Fix missing argument to rpc_set_user Requests were unable to traverse a collective. --- confluent_server/confluent/config/configmanager.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/confluent_server/confluent/config/configmanager.py b/confluent_server/confluent/config/configmanager.py index c2138354..440eaf6c 100644 --- a/confluent_server/confluent/config/configmanager.py +++ b/confluent_server/confluent/config/configmanager.py @@ -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):