diff --git a/karapace/kafka_utils.py b/karapace/kafka_utils.py index 33a55a580..43b7a7ec4 100644 --- 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"],