05-14-2018 02:17 AM
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.