diff options
| author | Dana Powers <dana.powers@gmail.com> | 2016-05-22 17:14:03 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2016-05-22 17:14:03 -0700 |
| commit | 1d4251a9efa4c5466ba5095f3ba199bf082a72b5 (patch) | |
| tree | 0393a7b7768f449174216fb6b0702a87844a5a81 /kafka/errors.py | |
| parent | 96530f6a9c4a31d23b069ba162dba6cf45a5efd0 (diff) | |
| download | kafka-python-1d4251a9efa4c5466ba5095f3ba199bf082a72b5.tar.gz | |
Use standard LZ4 framing for v1 messages / kafka 0.10 (#695)
* LZ4 framing fixed in 0.10 / message v1 -- retain broken lz4 code for compatibility
* lz4f does not support easy incremental decompression - raise RuntimeError
* Update lz4 codec tests
Diffstat (limited to 'kafka/errors.py')
| -rw-r--r-- | kafka/errors.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/kafka/errors.py b/kafka/errors.py index a34ffef..6960810 100644 --- a/kafka/errors.py +++ b/kafka/errors.py @@ -81,8 +81,8 @@ class OffsetOutOfRangeError(BrokerResponseError): class InvalidMessageError(BrokerResponseError): errno = 2 message = 'INVALID_MESSAGE' - description = ('This indicates that a message contents does not match its' - ' CRC.') + description = ('This message has failed its CRC checksum, exceeds the' + ' valid size, or is otherwise corrupt.') class UnknownTopicOrPartitionError(BrokerResponseError): |