openstack/deb-python-kafka
Code Issues Proposed changes

error handling fix

Browse Source
This commit is contained in:
Ben Frederickson
2012-10-25 10:32:13 -07:00
parent 86b0e41074
commit 03d60f08da
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
kafka/client.py
View File

@@ -24,7 +24,7 @@ class KafkaException(Exception):
def __init__(self, errorType): def __init__(self, errorType):
self.errorType = errorType self.errorType = errorType
def __str__(self): def __str__(self):
return str(errorType) return str(self.errorType)
Message = namedtuple("Message", ["magic", "attributes", "crc", "payload"]) Message = namedtuple("Message", ["magic", "attributes", "crc", "payload"])
FetchRequest = namedtuple("FetchRequest", ["topic", "partition", "offset", "size"]) FetchRequest = namedtuple("FetchRequest", ["topic", "partition", "offset", "size"])