typo

dpkp · Mar 30, 2019 · fb75f42 · fb75f42
1 parent d36ec96
commit fb75f42
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/kafka/conn.py b/kafka/conn.py
@@ -832,7 +832,7 @@ def _send(self, request, blocking=True):
         with self._lock:
             if self.state not in (ConnectionStates.AUTHENTICATING,
                                   ConnectionStates.CONNECTED):
-                return future.failure(Errors.NodeNotReady(str(self)))
+                return future.failure(Errors.NodeNotReadyError(str(self)))
 
             correlation_id = self._protocol.send_request(request)