Dont prioritize metadata requests over consumer group api calls

dpkp · Mar 9, 2017 · e965dcc · e965dcc
1 parent 239dadc
commit e965dcc
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/kafka/coordinator/base.py b/kafka/coordinator/base.py
@@ -287,7 +287,7 @@ def _send_join_group_request(self):
             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 @@ def _send_group_coordinator_request(self):
         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 @@ def _send_heartbeat_request(self):
             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)