From 5c477f2642a4d0b6bcb4010447a5e113fedf3e7f Mon Sep 17 00:00:00 2001
From: Ian Bucad <ian.bucad@datadoghq.com>
Date: Mon, 30 Dec 2019 07:51:07 +0800
Subject: Fixes KafkaAdminClient returning `IncompatibleBrokerVersion` when
 passing an `api_version` (#1953)

---
 kafka/admin/client.py | 1 +
 1 file changed, 1 insertion(+)

(limited to 'kafka/admin/client.py')

diff --git a/kafka/admin/client.py b/kafka/admin/client.py
index dd198c0..e9be1d8 100644
--- a/kafka/admin/client.py
+++ b/kafka/admin/client.py
@@ -204,6 +204,7 @@ class KafkaAdminClient(object):
         self._client = KafkaClient(metrics=self._metrics,
                                    metric_group_prefix='admin',
                                    **self.config)
+        self._client.check_version()
 
         # Get auto-discovered version from client if necessary
         if self.config['api_version'] is None:
-- 
cgit v1.2.1