feat(ingest): pass timeout config in kafka admin client api calls (#6863)

This commit is contained in:
Mayuri Nehate 2022-12-28 02:15:11 +05:30 committed by GitHub
parent a5b5abf270
commit 14b48489d4
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

@ -417,7 +417,8 @@ class KafkaSource(StatefulIngestionSourceBase):
configs: Dict[
ConfigResource, concurrent.futures.Future
] = self.admin_client.describe_configs(
resources=[ConfigResource(ResourceType.TOPIC, t) for t in topics]
resources=[ConfigResource(ResourceType.TOPIC, t) for t in topics],
request_timeout=self.source_config.connection.client_timeout_seconds,
)
logger.debug("Waiting for config details futures to complete")
concurrent.futures.wait(configs.values())