Support Questions
Find answers, ask questions, and share your expertise
Announcements
Alert: Welcome to the Unified Cloudera Community. Former HCC members be sure to read and learn how to activate your account here.

Kafka Exception cause: Record is corrupt (stored crc = 51, computed crc = 1691349309)

Kafka Exception cause: Record is corrupt (stored crc = 51, computed crc = 1691349309)

Expert Contributor

Hi,

 

Any idea on how to deal with below kafka issue?

 

org.apache.kafka.common.KafkaException: Record for partition Test_New at offset 0 is invalid, cause: Record is corrupt (stored crc = 51, computed crc = 132934330)

 

As a background, we have upgraded from CDH 5.11.x to CDH 5.14.x and all was fine for few days. But then we has some issues with storage on zookeeper servers and then the issue popped. Not sure if it has any relation with Zookeeper.

Don't have an account?
Coming from Hortonworks? Activate your account here