We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 6c9f728 commit ff56bdbCopy full SHA for ff56bdb
kafka/errors.py
@@ -73,10 +73,9 @@ class BrokerResponseError(KafkaError):
73
74
def __str__(self):
75
"""Add errno to standard KafkaError str"""
76
- return '[Error {0}] {1}: {2}'.format(
+ return '[Error {0}] {1}'.format(
77
self.errno,
78
- self.__class__.__name__,
79
- super(KafkaError, self).__str__()) # pylint: disable=bad-super-call
+ super(BrokerResponseError, self).__str__())
80
81
82
class NoError(BrokerResponseError):
@@ -154,6 +153,7 @@ class BrokerNotAvailableError(BrokerResponseError):
154
153
description = ('This is not a client facing error and is used mostly by'
155
' tools when a broker is not alive.')
156
+
157
class ReplicaNotAvailableError(BrokerResponseError):
158
errno = 9
159
message = 'REPLICA_NOT_AVAILABLE'
0 commit comments