summaryrefslogtreecommitdiff
path: root/kafka/conn.py
diff options
context:
space:
mode:
authorOmar Ghishan <omar.ghishan@rd.io>2014-01-08 11:46:10 -0800
committerOmar Ghishan <omar.ghishan@rd.io>2014-01-08 11:46:10 -0800
commita0c7141e2cc7399a9472a8169ea5f730f0407386 (patch)
treed644ae9f9c312b2a3aa5a384a176ebbe092ec5a6 /kafka/conn.py
parent317c8480164763b484fa82d0e0273107bc861538 (diff)
downloadkafka-python-a0c7141e2cc7399a9472a8169ea5f730f0407386.tar.gz
Change log.error() back to log.exception()
Diffstat (limited to 'kafka/conn.py')
-rw-r--r--kafka/conn.py6
1 files changed, 3 insertions, 3 deletions
diff --git a/kafka/conn.py b/kafka/conn.py
index 9a6633a..c80f428 100644
--- a/kafka/conn.py
+++ b/kafka/conn.py
@@ -48,8 +48,8 @@ class KafkaConnection(local):
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 @@ class KafkaConnection(local):
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):