Dont need to refresh metadata on GroupCoordinatorNotAvailableErrors

2016-01-24 13:23:26 -08:00
parent 6eecabfe85
commit 48e96822b3
1 changed files with 4 additions and 1 deletions
--- a/kafka/coordinator/base.py
+++ b/kafka/coordinator/base.py
@@ -200,7 +200,10 @@ class BaseCoordinator(object):
            self._client.poll(future=future)

            if future.failed():
-                if future.retriable():
+                if isinstance(future.exception,
+                              Errors.GroupCoordinatorNotAvailableError):
+                    continue
+                elif future.retriable():
                    metadata_update = self._client.cluster.request_update()
                    self._client.poll(future=metadata_update)
                else: