Merge pull request #730 from Aiven-Open/backup-admin-sasl

Enable SASL authentication in backup code
Aiven-Open · Oct 3, 2023 · 8a4ff32 · 8a4ff32
2 parents 8d4b05c + d9e9d29
commit 8a4ff32
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/karapace/kafka_utils.py b/karapace/kafka_utils.py
@@ -17,6 +17,9 @@ def kafka_admin_from_config(config: Config) -> KafkaAdminClient:
         bootstrap_servers=config["bootstrap_uri"],
         client_id=config["client_id"],
         security_protocol=config["security_protocol"],
+        sasl_mechanism=config["sasl_mechanism"],
+        sasl_plain_username=config["sasl_plain_username"],
+        sasl_plain_password=config["sasl_plain_password"],
         ssl_cafile=config["ssl_cafile"],
         ssl_certfile=config["ssl_certfile"],
         ssl_keyfile=config["ssl_keyfile"],