F

使用kafka-log-dirs.sh工具检查日志一致性，问题目录报了KafkaStorageException

影响这个的问题出现的，我列几种：

1. /tmp 临时目录
2. 目录格式
3. 目录权限（目录不干净，有其他文件权限影响了）

其他如果没有更多的错误，我也帮你分析不出来。

没有放在/tmp下，节点配置了好几个目录，只有这一个目录出现这种情况，而且目录的权限也是对的。
查看日志，最初是在写一个topic分片的leader-epoch-checkpoint报了error，后面就是stop fetcher for partitions xxx and stopped moving logs for partitions because they are in the failed diractory /xx/kafka-logs. Stopping serving logs in dir /xx/kafka-logs。

你不会把日志目录放在/tmp/目录下了吧，这个目录会被系统定时回收。

ps： 一般这个错误数据被删，不匹配，这么引起的。

检查日志文件一致性： 使用工具如 kafka-log-dirs.sh（Kafka 提供的工具）来检查日志目录的一致性和完整性，确保没有损坏的日志段。

新版本的就是删除不了，配置没用，你可以重启一下诸如kafka-manager这样得web监控，处于不活跃状态的消费者组就删除了。

这个新版本的删除不了，会定期清除掉，0.11之前的可以通过命令删除。