diff options
| author | Dana Powers <dana.powers@rd.io> | 2014-09-01 02:25:05 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2014-09-01 18:02:41 -0700 |
| commit | 6c0d9137eae9bd875a7a7ab70d3285dd74f6701b (patch) | |
| tree | ec231a6f60a79deac1d36bffc58d8579b7872da3 /kafka/common.py | |
| parent | 4da01fc3cee3b4b345eb31c7db017bfaab3a0776 (diff) | |
| download | kafka-python-6c0d9137eae9bd875a7a7ab70d3285dd74f6701b.tar.gz | |
if error code is not recognized in check_error: raise UnknownError
Diffstat (limited to 'kafka/common.py')
| -rw-r--r-- | kafka/common.py | 8 |
1 files changed, 6 insertions, 2 deletions
diff --git a/kafka/common.py b/kafka/common.py index e1713cf..6b73410 100644 --- a/kafka/common.py +++ b/kafka/common.py @@ -76,6 +76,9 @@ class KafkaError(RuntimeError): class BrokerResponseError(KafkaError): pass +class NoError(BrokerResponseError): + errno = 0 + message = 'SUCCESS' class UnknownError(BrokerResponseError): errno = -1 @@ -197,6 +200,7 @@ class UnsupportedCodecError(KafkaError): kafka_errors = { -1 : UnknownError, + 0 : NoError, 1 : OffsetOutOfRangeError, 2 : InvalidMessageError, 3 : UnknownTopicOrPartitionError, @@ -214,7 +218,7 @@ kafka_errors = { def check_error(response): - error = kafka_errors.get(response.error) - if error: + error = kafka_errors.get(response.error, UnknownError) + if error is not NoError: raise error(response) |