Skip to content

Commit 5c477f2

Browse files
ian28223dpkp
authored andcommitted
Fixes KafkaAdminClient returning IncompatibleBrokerVersion when passing an api_version (#1953)
1 parent 875dd85 commit 5c477f2

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

kafka/admin/client.py

+1
Original file line numberDiff line numberDiff line change
@@ -204,6 +204,7 @@ def __init__(self, **configs):
204204
self._client = KafkaClient(metrics=self._metrics,
205205
metric_group_prefix='admin',
206206
**self.config)
207+
self._client.check_version()
207208

208209
# Get auto-discovered version from client if necessary
209210
if self.config['api_version'] is None:

0 commit comments

Comments
 (0)