socket.sendall should always raise an exception on error; remove extra return val check in KafkaConnection.send()

1 files changed, 7 insertions, 6 deletions

diff --git a/kafka/conn.py b/kafka/conn.py
index 78fb565..ba0b996 100644
--- a/kafka/conn.py
+++ b/kafka/conn.py
@@ -106,14 +106,15 @@ class KafkaConnection(local):
 
     def send(self, request_id, payload):
         "Send a request to Kafka"
+
         log.debug("About to send %d bytes to Kafka, request %d" % (len(payload), request_id))
+
+        # Make sure we have a connection
+        if self._dirty or not self._sock:
+            self.reinit()
+
         try:
-            if self._dirty or not self._sock:
-                self.reinit()
-            log.debug("Sending payload %s" % (payload,))
-            sent = self._sock.sendall(payload)
-            if sent is not None:
-                self._raise_connection_error()
+            self._sock.sendall(payload)
         except socket.error:
             log.exception('Unable to send payload to Kafka')
             self._raise_connection_error()