From 04b370427a2381e513bf4af01d01b983ecd8fa07 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Wed, 13 Mar 2019 18:34:43 -0700 Subject: Dont recheck version if api_versions data is already cached --- kafka/conn.py | 3 +++ 1 file changed, 3 insertions(+) diff --git a/kafka/conn.py b/kafka/conn.py index 4f324c8..4781b9a 100644 --- a/kafka/conn.py +++ b/kafka/conn.py @@ -912,6 +912,9 @@ class BrokerConnection(object): return self._api_versions def get_api_versions(self): + if self._api_versions is not None: + return self._api_versions + version = self.check_version() if version < (0, 10, 0): raise Errors.UnsupportedVersionError( -- cgit v1.2.1