From 7d57a81622f4b673049e3da2b7bc483b2bdffc93 Mon Sep 17 00:00:00 2001 From: Ayush Shah Date: Wed, 27 Apr 2022 17:46:27 +0530 Subject: [PATCH] Fixes consumer config (#4527) --- ingestion/src/metadata/ingestion/source/kafka.py | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/ingestion/src/metadata/ingestion/source/kafka.py b/ingestion/src/metadata/ingestion/source/kafka.py index 00ee1b2454d..603891bdf80 100644 --- a/ingestion/src/metadata/ingestion/source/kafka.py +++ b/ingestion/src/metadata/ingestion/source/kafka.py @@ -86,12 +86,12 @@ class KafkaSource(Source[CreateTopicRequest]): self.schema_registry_client = SchemaRegistryClient( self.service_connection.schemaRegistryConfig ) - self.admin_client = AdminClient( - { - "bootstrap.servers": self.service_connection.bootstrapServers, - "session.timeout.ms": 6000, - } - ) + admin_client_config = self.service_connection.consumerConfig + admin_client_config[ + "bootstrap.servers" + ] = self.service_connection.bootstrapServers + admin_client_config["session.timeout.ms"] = 6000 + self.admin_client = AdminClient(admin_client_config) @classmethod def create(cls, config_dict, metadata_config: OpenMetadataConnection):