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
