From 8a7d4cd66a028f0e28012bde75a12d4ff3da4ee9 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Sun, 18 Jun 2017 23:55:39 -0700 Subject: Backoff on unavailable group coordinator retry --- kafka/coordinator/base.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/kafka/coordinator/base.py b/kafka/coordinator/base.py index 85b1d78..a231857 100644 --- a/kafka/coordinator/base.py +++ b/kafka/coordinator/base.py @@ -219,6 +219,8 @@ class BaseCoordinator(object): log.debug('Requesting metadata for group coordinator request: %s', future.exception) metadata_update = self._client.cluster.request_update() self._client.poll(future=metadata_update) + else: + time.sleep(self.config['retry_backoff_ms'] / 1000) else: raise future.exception # pylint: disable-msg=raising-bad-type -- cgit v1.2.1