Merge pull request #620 from Acuion/acuion/fix/original-mechanism-in-…

…rest-proxy fix: do not override SASL mechanism for user REST proxy
Aiven-Open · May 17, 2023 · 56f1139 · 56f1139
2 parents 9b17e18 + ee798c3
commit 56f1139
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/karapace/kafka_rest_apis/__init__.py b/karapace/kafka_rest_apis/__init__.py
@@ -284,7 +284,8 @@ async def get_user_proxy(self, request: HTTPRequest) -> "UserRestProxy":
                         config["security_protocol"] = (
                             "SASL_SSL" if config["security_protocol"] in ("SSL", "SASL_SSL") else "SASL_PLAINTEXT"
                         )
-                        config["sasl_mechanism"] = "PLAIN"
+                        if config["sasl_mechanism"] is None:
+                            config["sasl_mechanism"] = "PLAIN"
                         config["sasl_plain_username"] = auth.login
                         config["sasl_plain_password"] = auth.password
                         self.proxies[key] = UserRestProxy(config, self.kafka_timeout, self.serializer)