kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Roger Hoover <roger.hoo...@gmail.com>
Subject Re: kafka.message.InvalidMessageException: Message is corrupt crc
Date Thu, 14 May 2015 06:40:53 GMT
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 <scguo@iflytek.com> wrote:

> 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)
>
>          at
> kafka.consumer.ConsumerIterator.makeNext(ConsumerIterator.scala:33)
>
>          at
> kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66)
>
>          at kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58)
>
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message