From e965dccddcc6662e0389922d74b397a8d114c607 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Thu, 9 Mar 2017 10:50:07 -0800 Subject: Dont prioritize metadata requests over consumer group api calls --- kafka/coordinator/base.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/kafka/coordinator/base.py b/kafka/coordinator/base.py index 4a851bd..2f08c19 100644 --- a/kafka/coordinator/base.py +++ b/kafka/coordinator/base.py @@ -287,7 +287,7 @@ class BaseCoordinator(object): e = Errors.GroupCoordinatorNotAvailableError(self.coordinator_id) return Future().failure(e) - elif not self._client.ready(self.coordinator_id): + elif not self._client.ready(self.coordinator_id, metadata_priority=False): e = Errors.NodeNotReadyError(self.coordinator_id) return Future().failure(e) @@ -479,7 +479,7 @@ class BaseCoordinator(object): if node_id is None: return Future().failure(Errors.NoBrokersAvailable()) - elif not self._client.ready(node_id): + elif not self._client.ready(node_id, metadata_priority=False): e = Errors.NodeNotReadyError(node_id) return Future().failure(e) @@ -573,7 +573,7 @@ class BaseCoordinator(object): e = Errors.GroupCoordinatorNotAvailableError(self.coordinator_id) return Future().failure(e) - elif not self._client.ready(self.coordinator_id): + elif not self._client.ready(self.coordinator_id, metadata_priority=False): e = Errors.NodeNotReadyError(self.coordinator_id) return Future().failure(e) -- cgit v1.2.1