)
kafka.message.InvalidMessageException: Message is corrupt (stored crc =
1192544432, computed crc = 3083615698)
INFO [KafkaApi-0] Close connection due to error handling produce request with
correlation id 6314650 from client id kafka-python with ack=0
(kafka.server.KafkaApis)
We are getting this for only certain
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
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
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
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
