diff options
| -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' |