From cceaf4ae0982a78bdaef39ce1c9635e260bff709 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Mon, 19 Jun 2017 09:18:56 -0700 Subject: [PATCH] Backoff on unavailable group coordinator retry (#1125) --- 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