diff --git a/mlrun/datastore/sources.py b/mlrun/datastore/sources.py
index 0de1c63e34a..3ff0c83d633 100644
--- a/mlrun/datastore/sources.py
+++ b/mlrun/datastore/sources.py
@@ -803,7 +803,7 @@ def __init__(
         }
         if sasl_user and sasl_pass:
             attrs["sasl_user"] = sasl_user
-            attrs["sasl_user"] = sasl_user
+            attrs["sasl_pass"] = sasl_pass
         super().__init__(attributes=attrs, **kwargs)
 
     def add_nuclio_trigger(self, function):