apache-kafka - 如果删除 Kafka 快照文件会发生什么？

Question

问题很简单。如果删除 Kafka 日志目录中的 Kafka 快照文件会发生什么。卡夫卡能启动吗？它是否必须对某些东西进行缓慢的重建？

附加问题快照文件究竟包含什么？

这个问题的背景

由于所有代理同时停机以及导致代理损坏，我有一个集群已经关闭了几天。现在，当它启动时，它会静默数小时(在日志文件中没有新消息)。通过检查 JVM，我发现所有(非常有限的)cpu 使用都花在了 loadproducersfromlog 中。功能/方法。通过阅读上面的评论，建议这是从快照中恢复生产者状态的尝试。我不在乎这个。我只是想让我的经纪人回来，所以我在想是否可以简单地删除快照以重新启动 Kafka。

Answer 1

如果快照文件被删除，在启动方法 log.loadSegmentFiles() 期间，即使存在日志和索引文件，也必须读取分区中的所有消息以重新创建快照。这将增加加载分区的时间。

快照文件的内容请引用ProducerStateManager中的writeSnapshot()。
https://github.com/apache/kafka/blob/980b725bb09ee42469534bf50d01118ce650880a/core/src/main/scala/kafka/log/ProducerStateManager.scala