kafka.message.InvalidMessageException: Message is corrupt crc

[scguo]

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)