Eliminate NoBrokersAvailableError

kafka/consumer/group.py

@@ -212,7 +212,7 @@ class KafkaConsumer:
             None, the client will attempt to determine the broker version via
             ApiVersionsRequest API or, for brokers earlier than 0.10, probing
             various known APIs. Dynamic version checking is performed eagerly
-            during __init__ and can raise NoBrokersAvailableError if no connection
+            during __init__ and can raise KafkaTimeoutError if no connection
             was made before timeout (see api_version_auto_timeout_ms below).
             Different versions enable different functionality.
 

kafka/coordinator/base.py

@@ -289,7 +289,7 @@ def ensure_coordinator_ready(self, timeout_ms=None):
                 if self.config['api_version'] < (0, 8, 2):
                     maybe_coordinator_id = self._client.least_loaded_node()
                     if maybe_coordinator_id is None:
-                        future = Future().failure(Errors.NoBrokersAvailable())
+                        future = Future().failure(Errors.NodeNotReadyError('coordinator'))
                     else:
                         self.coordinator_id = maybe_coordinator_id
                         self._client.maybe_connect(self.coordinator_id)
@@ -796,7 +796,7 @@ def _send_group_coordinator_request(self):
         """
         node_id = self._client.least_loaded_node()
         if node_id is None:
-            return Future().failure(Errors.NoBrokersAvailable())
+            return Future().failure(Errors.NodeNotReadyError('coordinator'))
 
         elif not self._client.ready(node_id, metadata_priority=False):
             e = Errors.NodeNotReadyError(node_id)

kafka/errors.py

@@ -62,11 +62,6 @@ class MetadataEmptyBrokerList(KafkaError):
     retriable = True
 
 
-class NoBrokersAvailable(KafkaError):
-    retriable = True
-    invalid_metadata = True
-
-
 class NoOffsetForPartitionError(KafkaError):
     pass
 

kafka/producer/kafka.py

@@ -327,7 +327,7 @@ class KafkaProducer:
             None, the client will attempt to determine the broker version via
             ApiVersionsRequest API or, for brokers earlier than 0.10, probing
             various known APIs. Dynamic version checking is performed eagerly
-            during __init__ and can raise NoBrokersAvailableError if no connection
+            during __init__ and can raise KafkaTimeoutError if no connection
             was made before timeout (see api_version_auto_timeout_ms below).
             Different versions enable different functionality.