From 8f1ef49cdbcf99f3cda8712f99a1a91759b82b00 Mon Sep 17 00:00:00 2001 From: Nahuel Date: Sun, 4 Sep 2022 15:59:11 +0200 Subject: [PATCH] Fix issue ingesting Kafka when the basic auth is enabled in the Schema Registry (#7203) --- ingestion/src/metadata/utils/connections.py | 9 +++------ 1 file changed, 3 insertions(+), 6 deletions(-) diff --git a/ingestion/src/metadata/utils/connections.py b/ingestion/src/metadata/utils/connections.py index f82fb98818f..79957cae7cb 100644 --- a/ingestion/src/metadata/utils/connections.py +++ b/ingestion/src/metadata/utils/connections.py @@ -362,13 +362,10 @@ def _(connection, verbose: bool = False) -> KafkaClient: consumer_config["group.id"] = "openmetadata-consumer" if "auto.offset.reset" not in consumer_config: consumer_config["auto.offset.reset"] = "earliest" - - for key in connection.schemaRegistryConfig: - consumer_config["schema.registry." + key] = connection.schemaRegistryConfig[ - key - ] logger.debug(f"Using Kafka consumer config: {consumer_config}") - consumer_client = AvroConsumer(consumer_config) + consumer_client = AvroConsumer( + consumer_config, schema_registry=schema_registry_client + ) return KafkaClient( admin_client=admin_client,