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

Posted to users@kafka.apache.org by "Mhaskar, Tushar" <tm...@paypal.com.INVALID> on 2016/04/26 05:28:23 UTC

kafka.message.InvalidMessageException: Message is corrupt

Hi ,

We are pushing data to Kafka 0.9.0.0 broker using a python client.
We are getting the below error in broker logs.

ERROR [Replica Manager on Broker 0]: Error processing append operation on partition [gps.logging.akamailogs.web.prod,20] (kafka.server.ReplicaManager)
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 partitions. Any pointers on how to resolve this one.

Thanks
Tushar