Change log.error() back to log.exception()

Author: rdiomar

kafka/conn.py

@@ -48,8 +48,8 @@ def _read_bytes(self, num_bytes):
         while bytes_left:
             try:
                 data = self._sock.recv(bytes_left)
-            except socket.error, e:
-                log.error('Unable to receive data from Kafka: %s', e)
+            except socket.error:
+                log.exception('Unable to receive data from Kafka')
                 self._raise_connection_error()
             if data == '':
                 log.error("Not enough data to read this response")
@@ -76,7 +76,7 @@ def send(self, request_id, payload):
             if sent is not None:
                 self._raise_connection_error()
         except socket.error, e:
-            log.error('Unable to send payload to Kafka: %s', e)
+            log.exception('Unable to send payload to Kafka')
             self._raise_connection_error()
 
     def recv(self, request_id):

kafka/producer.py

@@ -67,8 +67,8 @@ def _send_upstream(topic, queue, client, batch_time, batch_size,
             client.send_produce_request(reqs,
                                         acks=req_acks,
                                         timeout=ack_timeout)
-        except Exception as e:
-            log.error("Unable to send message: %s", e)
+        except Exception:
+            log.exception("Unable to send message")
 
 
 class Producer(object):
@@ -144,9 +144,9 @@ def send_messages(self, partition, *msg):
             try:
                 resp = self.client.send_produce_request([req], acks=self.req_acks,
                                                         timeout=self.ack_timeout)
-            except Exception as e:
-                log.error("Unable to send messages: %s", e)
-                raise e
+            except Exception:
+                log.exception("Unable to send messages")
+                raise
         return resp
 
     def stop(self, timeout=1):