Enable SASL authentication in backup code

Pass SASL related connection parameters to KafkaAdminClient so backup code can access Kafka also with SASL authentication.
Aiven-Open · Oct 3, 2023 · d9e9d29 · d9e9d29
1 parent 8d4b05c
commit d9e9d29
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"],