From 30c86b08c48f47f180d45ebda2a4ec1bcd6aa62a Mon Sep 17 00:00:00 2001
From: Gal Topper <galt@iguazio.com>
Date: Sun, 23 Oct 2022 13:58:19 +0800
Subject: [PATCH] [Datastore] Fix SASL bug in `KafkaSource` (#2504)

[ML-2685](https://jira.iguazeng.com/browse/ML-2685)
---
 mlrun/datastore/sources.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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):