From 59c051314890a0a6713e6fdb28d74bc3dc053aa9 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Wed, 30 Dec 2015 13:17:16 -0800 Subject: [PATCH] Catch GroupCoordinatorNotAvailableError in GroupCoordinatorResponse handler --- kafka/coordinator/abstract.py | 3 +++ 1 file changed, 3 insertions(+) diff --git a/kafka/coordinator/abstract.py b/kafka/coordinator/abstract.py index 7c16034..ca5d38d 100644 --- a/kafka/coordinator/abstract.py +++ b/kafka/coordinator/abstract.py @@ -470,6 +470,9 @@ class AbstractCoordinator(object): if self.generation > 0: self.heartbeat_task.reset() future.success(self.coordinator_id) + elif error_type is Errors.GroupCoordinatorNotAvailableError: + log.debug("Group Coordinator Not Available; retry") + future.failure(error_type()) elif error_type is Errors.GroupAuthorizationFailedError: error = error_type(self.group_id) log.error("Group Coordinator Request failed: %s", error)