diff options
author | Dana Powers <dana.powers@gmail.com> | 2016-11-18 09:06:21 -0800 |
---|---|---|
committer | Dana Powers <dana.powers@gmail.com> | 2016-11-18 09:06:21 -0800 |
commit | da8d4c1e8b8482b767e7288e096fa474a36092cd (patch) | |
tree | 0e8fa6cc141bcf876bd7d381f60c63798a1e9bf9 | |
parent | 77591afa789a4752f4d385228bea980f448f6a08 (diff) | |
download | kafka-python-kafka_error_str.tar.gz |
Args are optional in BrokerResponseError strkafka_error_str
-rw-r--r-- | kafka/errors.py | 6 |
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' |