[Datastore] Fix SASL bug in KafkaSource (mlrun#2504)

[ML-2685](https://jira.iguazeng.com/browse/ML-2685)
Penumbra69 · Oct 23, 2022 · 30c86b0 · 30c86b0
1 parent d4cd9bd
commit 30c86b0
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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):