You are viewing a plain text version of this content. The canonical link for it is here.

Posted to users@kafka.apache.org by Fredrik S Loekke <fs...@lindcapital.com> on 2014/11/03 12:31:54 UTC

kafka.message.InvalidMessageException: Message is corrupt

Hi

We are experimenting with running kafka server on a windows machine, but keep getting exeptions when producing a lot of messages (in the neighborhood of 1 million)..

kafka.message.InvalidMessageException: Message is corrupt (stored crc = 29639294
31, computed crc = 2364631640)
        at kafka.message.Message.ensureValid(Message.scala:166)
        at kafka.log.Log$$anonfun$analyzeAndValidateMessageSet$1.apply(Log.scala
:330)
        at kafka.log.Log$$anonfun$analyzeAndValidateMessageSet$1.apply(Log.scala
:318)
        at scala.collection.Iterator$class.foreach(Iterator.scala:772)
        at kafka.utils.IteratorTemplate.foreach(IteratorTemplate.scala:32)
        at kafka.log.Log.analyzeAndValidateMessageSet(Log.scala:318)
        at kafka.log.Log.append(Log.scala:231)

Any suggestions?

Best regards / Med venlig hilsen

Fredrik Skeel Løkke
Software Developer ǀ IT & Analysis

Mob.: +45 3176 8438
fsl@lindcapital.com<ma...@lindcapital.com>

[Beskrivelse: Beskrivelse: Beskrivelse: Beskrivelse: cid:image001.png@01CD4A0C.218B6960]

Lind Capital A/S
Værkmestergade 3, 2
DK-8000 Aarhus C
www.lindcapital.com<http://www.lindcapital.com/>
Follow us on
[linkedin]<http://www.linkedin.com/company/lind-capital-a-s>  [facebook] <http://www.facebook.com/LindCapital>

Re: kafka.message.InvalidMessageException: Message is corrupt

Posted by Jun Rao <ju...@gmail.com>.

Are you using the java producer?

Thanks,

Jun

On Mon, Nov 3, 2014 at 3:31 AM, Fredrik S Loekke <fs...@lindcapital.com>
wrote:

>  Hi
>
>
>
> We are experimenting with running kafka server on a windows machine, but
> keep getting exeptions when producing a lot of messages (in the
> neighborhood of 1 million)..
>
>
>
> kafka.message.InvalidMessageException: Message is corrupt (stored crc =
> 29639294
>
> 31, computed crc = 2364631640)
>
>         at kafka.message.Message.ensureValid(Message.scala:166)
>
>         at
> kafka.log.Log$$anonfun$analyzeAndValidateMessageSet$1.apply(Log.scala
>
> :330)
>
>         at
> kafka.log.Log$$anonfun$analyzeAndValidateMessageSet$1.apply(Log.scala
>
> :318)
>
>         at scala.collection.Iterator$class.foreach(Iterator.scala:772)
>
>         at kafka.utils.IteratorTemplate.foreach(IteratorTemplate.scala:32)
>
>         at kafka.log.Log.analyzeAndValidateMessageSet(Log.scala:318)
>
>         at kafka.log.Log.append(Log.scala:231)
>
>
>
> Any suggestions?
>
>
>
> Best regards / Med venlig hilsen
>
>
>
> *Fredrik Skeel Løkke*
>
> Software Developer ǀ IT & Analysis
>
>
>
> Mob.: +45 3176 8438
>
> fsl@lindcapital.com
>
>
>
> [image: Beskrivelse: Beskrivelse: Beskrivelse: Beskrivelse:
> cid:image001.png@01CD4A0C.218B6960]
>
>
>
> Lind Capital A/S
>
> Værkmestergade 3, 2
>
> DK-8000 Aarhus C
>
> www.lindcapital.com
>
> Follow us on
>
> [image: linkedin] <http://www.linkedin.com/company/lind-capital-a-s>  [image:
> facebook] <http://www.facebook.com/LindCapital>
>
>
>