Are you using snappy compression? I ran into an issue with message
corruption with the new producer, snappy compression, and broker restart.
On Mon, May 4, 2015 at 12:55 AM, scguo wrote:
> Hi
>
>
>
> Here is my questions.
>
>
>
> kafka.message.InvalidMessageException: Message is corrupt (store
Hi
Here is my questions.
kafka.message.InvalidMessageException: Message is corrupt (stored crc =
301919704, computed crc = 2370805243)
at kafka.message.Message.ensureValid(Message.scala:166)
at
kafka.consumer.ConsumerIterator.makeNext(ConsumerIterator.scala:102)
