File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -206,7 +206,7 @@ def __init__(self, **configs):
206
206
self ._client = KafkaClient (metrics = self ._metrics ,
207
207
metric_group_prefix = 'admin' ,
208
208
** self .config )
209
- self ._client .check_version ()
209
+ self ._client .check_version (timeout = ( self . config [ 'api_version_auto_timeout_ms' ] / 1000 ) )
210
210
211
211
# Get auto-discovered version from client if necessary
212
212
if self .config ['api_version' ] is None :
@@ -273,7 +273,7 @@ def _refresh_controller_id(self):
273
273
response = future .value
274
274
controller_id = response .controller_id
275
275
# verify the controller is new enough to support our requests
276
- controller_version = self ._client .check_version (controller_id )
276
+ controller_version = self ._client .check_version (controller_id , timeout = ( self . config [ 'api_version_auto_timeout_ms' ] / 1000 ) )
277
277
if controller_version < (0 , 10 , 0 ):
278
278
raise IncompatibleBrokerVersion (
279
279
"The controller appears to be running Kafka {}. KafkaAdminClient requires brokers >= 0.10.0.0."
You can’t perform that action at this time.
0 commit comments