Backoff on unavailable group coordinator retry (#1125)

2017-06-19 09:18:56 -07:00
parent bbbac3dc36
commit cceaf4ae09
1 changed files with 2 additions and 0 deletions
--- 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