yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-11-12 08:52:38 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fixes consumer config (#4527)

Browse Source
This commit is contained in:
Ayush Shah 2022-04-27 17:46:27 +05:30 committed by GitHub
parent e5a4cfd648
commit 7d57a81622
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
ingestion/src/metadata/ingestion/source/kafka.py
View File

@ -86,12 +86,12 @@ class KafkaSource(Source[CreateTopicRequest]):
self.schema_registry_client = SchemaRegistryClient( self.schema_registry_client = SchemaRegistryClient(
self.service_connection.schemaRegistryConfig self.service_connection.schemaRegistryConfig
) )
self.admin_client = AdminClient( admin_client_config = self.service_connection.consumerConfig
{ admin_client_config[
"bootstrap.servers": self.service_connection.bootstrapServers, "bootstrap.servers"
"session.timeout.ms": 6000, ] = self.service_connection.bootstrapServers
} admin_client_config["session.timeout.ms"] = 6000
) self.admin_client = AdminClient(admin_client_config)
@classmethod @classmethod
def create(cls, config_dict, metadata_config: OpenMetadataConnection): def create(cls, config_dict, metadata_config: OpenMetadataConnection):