提问说明:你好请问这个错误是什么原因导致的
[2021-03-04 12:04:42,456] ERROR There was an error in one of the threads during logs loading: org.apache.kafka.common.errors.CorruptRecordException: Found record size 0 smaller than minimum record overhead (14) in file /tmp/kafka-logs/__consumer_offsets-29/00000000000001651869.log. (kafka.log.LogManager)
[2021-03-04 12:04:42,460] ERROR [KafkaServer id=0] Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer)
org.apache.kafka.common.errors.CorruptRecordException: Found record size 0 smaller than minimum record overhead (14) in file /tmp/kafka-logs/__consumer_offsets-29/00000000000001651869.log.
[2021-03-04 12:04:42,462] INFO [KafkaServer id=0] shutting down (kafka.server.KafkaServer)
不要把kafka的日志放在
这个目录下,会被系统清理的。
谢谢
请问这是什么原因导致的,我这边也碰到同样的问题
日志在临时目录,被系统回收了,导致kafka数据不匹配了。
你的答案