diff options
| author | Dana Powers <dana.powers@gmail.com> | 2019-03-13 18:34:43 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2019-03-13 19:00:32 -0700 |
| commit | 04b370427a2381e513bf4af01d01b983ecd8fa07 (patch) | |
| tree | bdf0ae31b36c2e401e89225f92f0bfab68931068 | |
| parent | 7965460a7253a5f5c23e7343c0c06c40e40f471e (diff) | |
| download | kafka-python-get_api_versions_fix.tar.gz | |
Dont recheck version if api_versions data is already cachedget_api_versions_fix
| -rw-r--r-- | kafka/conn.py | 3 |
1 files changed, 3 insertions, 0 deletions
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( |