Compressed messages generate an error with Kafka Broker version 0.11.x

WallarooLabs / pony-kafka

:horse: Pure Pony Kafka client

Other

57 stars 4 forks source link

Closed dipinhora closed 6 years ago

dipinhora commented 6 years ago

When compressed messages are sent to a Kafka Broker version 0.11.x it results in the following error from the broker:

Broker(2): This message has failed its CRC checksum, exceeds the valid size, or is otherwise corrupt.

This was discovered by @slfritchie.