summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorDana Powers <dana.powers@gmail.com>2016-11-18 09:06:21 -0800
committerDana Powers <dana.powers@gmail.com>2016-11-18 09:06:21 -0800
commitda8d4c1e8b8482b767e7288e096fa474a36092cd (patch)
tree0e8fa6cc141bcf876bd7d381f60c63798a1e9bf9
parent77591afa789a4752f4d385228bea980f448f6a08 (diff)
downloadkafka-python-kafka_error_str.tar.gz
Args are optional in BrokerResponseError strkafka_error_str
-rw-r--r--kafka/errors.py6
1 files changed, 3 insertions, 3 deletions
diff --git a/kafka/errors.py b/kafka/errors.py
index 069c9e4..97d9fb1 100644
--- a/kafka/errors.py
+++ b/kafka/errors.py
@@ -73,10 +73,9 @@ class BrokerResponseError(KafkaError):
def __str__(self):
"""Add errno to standard KafkaError str"""
- return '[Error {0}] {1}: {2}'.format(
+ return '[Error {0}] {1}'.format(
self.errno,
- self.__class__.__name__,
- super(KafkaError, self).__str__()) # pylint: disable=bad-super-call
+ super(BrokerResponseError, self).__str__())
class NoError(BrokerResponseError):
@@ -154,6 +153,7 @@ class BrokerNotAvailableError(BrokerResponseError):
description = ('This is not a client facing error and is used mostly by'
' tools when a broker is not alive.')
+
class ReplicaNotAvailableError(BrokerResponseError):
errno = 9
message = 'REPLICA_NOT_AVAILABLE'