diff options
| author | Dana Powers <dana.powers@gmail.com> | 2014-05-19 19:44:23 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2014-05-19 19:44:23 -0700 |
| commit | ae6b49aca13d2d1df7e7f884b2a99c34aa839e18 (patch) | |
| tree | ea717d58fc766cb5438239061e49b93286ad10c0 /kafka/common.py | |
| parent | b13fa3f4a284a6ed4d9fd5fc6abbc627cdfe02e2 (diff) | |
| parent | 805b52a34da9ce0dead80a64d7315412f2034673 (diff) | |
| download | kafka-python-ae6b49aca13d2d1df7e7f884b2a99c34aa839e18.tar.gz | |
Merge pull request #166 from patricklucas/teach_producers_about_compression
Add 'codec' parameter to Producer
Diffstat (limited to 'kafka/common.py')
| -rw-r--r-- | kafka/common.py | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/kafka/common.py b/kafka/common.py index d515532..209754b 100644 --- a/kafka/common.py +++ b/kafka/common.py @@ -170,6 +170,11 @@ class ConsumerNoMoreData(KafkaError): class ProtocolError(KafkaError): pass + +class UnsupportedCodecError(KafkaError): + pass + + kafka_errors = { -1 : UnknownError, 1 : OffsetOutOfRangeError, @@ -187,6 +192,7 @@ kafka_errors = { 13 : StaleLeaderEpochCodeError, } + def check_error(response): error = kafka_errors.get(response.error) if error: |