From 1d4251a9efa4c5466ba5095f3ba199bf082a72b5 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Sun, 22 May 2016 17:14:03 -0700 Subject: 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 --- kafka/errors.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'kafka/errors.py') 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): -- cgit v1.2.1