error handling fix

Ben Frederickson · Ben Frederickson · commit 03d60f08da80 · 2012-10-25T10:32:13.000-07:00
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"])
