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 <sc...@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) > >
