summaryrefslogtreecommitdiff
path: root/kafka/client.py
diff options
context:
space:
mode:
authorBen Frederickson <ben@zite.com>2012-10-25 10:32:13 -0700
committerBen Frederickson <ben@zite.com>2012-10-25 10:32:13 -0700
commit03d60f08da8090cfb175f2df0227dbdc2dbd13d7 (patch)
tree2a572718434d2e1eaf4f3e305e95ee69aa108fc8 /kafka/client.py
parent86b0e41074a9495bef65e4eea5d728aa9835f031 (diff)
downloadkafka-python-03d60f08da8090cfb175f2df0227dbdc2dbd13d7.tar.gz
error handling fix
Diffstat (limited to 'kafka/client.py')
-rw-r--r--kafka/client.py2
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/client.py b/kafka/client.py
index ad80773..7f5ad8e 100644
--- a/kafka/client.py
+++ b/kafka/client.py
@@ -24,7 +24,7 @@ class KafkaException(Exception):
def __init__(self, errorType):
self.errorType = errorType
def __str__(self):
- return str(errorType)
+ return str(self.errorType)
Message = namedtuple("Message", ["magic", "attributes", "crc", "payload"])
FetchRequest = namedtuple("FetchRequest", ["topic", "partition", "offset", "size"])