openstack/deb-python-kafka
Code Issues Proposed changes

Errors -> Error typo

Browse Source
This commit is contained in:
Oliver Jowett
2015-07-20 20:25:02 +00:00
parent 718e5fb66d
commit 3376ed1cef
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

@@ -171,7 +171,7 @@ class KafkaClient(object):
log.warning('KafkaUnavailableError attempting to send request '
'on topic %s partition %d', payload.topic, payload.partition)
topic_partition = (payload.topic, payload.partition)
responses[topic_partition] = FailedPayloadsErrors(payload)
responses[topic_partition] = FailedPayloadsError(payload)
# For each broker, send the list of request payloads
# and collect the responses and errors