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):