flume系列之:Caused by: org.apache.flume.channel.file.BadCheckpointException: The last checkpoint was not completed correctly, since Checkpoint file does not exist while metadata file does.
一、报错原因
- checkpoint文件不存在了
二、解决办法
- 修改kafka.consumer.group.id,重新启动
微信扫一扫
相关推荐