Merge pull request #4 from benfred/master

exception handling fix
dpkp · Oct 29, 2012 · 786b7f9 · 786b7f9
2 parents 86b0e41 + 03d60f0
commit 786b7f9
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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"])