summaryrefslogtreecommitdiff
path: root/kafka/client.py
diff options
context:
space:
mode:
authorOliver Jowett <oliver@mutability.co.uk>2015-07-20 20:25:02 +0000
committerOliver Jowett <oliver@mutability.co.uk>2015-07-20 20:25:02 +0000
commit3376ed1cef3e29877f773017117d90192ccf9a5e (patch)
treefdaf103677e2594932393adcafc057636b632703 /kafka/client.py
parent718e5fb66da5dca449aa31d305b8867fba4f783c (diff)
downloadkafka-python-3376ed1cef3e29877f773017117d90192ccf9a5e.tar.gz
Errors -> Error typo
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 dbd9863..87b51c3 100644
--- a/kafka/client.py
+++ b/kafka/client.py
@@ -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