diff --git a/kafka/coordinator/base.py b/kafka/coordinator/base.py index 28a33e5f0..b9b54ebb7 100644 --- a/kafka/coordinator/base.py +++ b/kafka/coordinator/base.py @@ -735,10 +735,6 @@ def _send_group_coordinator_request(self): if node_id is None: return Future().failure(Errors.NodeNotReadyError('coordinator')) - elif not self._client.ready(node_id, metadata_priority=False): - e = Errors.NodeNotReadyError(node_id) - return Future().failure(e) - max_version = 3 request = FindCoordinatorRequest( key=self.group_id,