Kafka分区的日志段中的领导者时代检查点有什么作用？

Question

Kafka分区的日志段中的领导者时代检查点有什么作用？

Answer 1

在Kafka中，领导者时代是指控制器先前分配的领导者数量。领导者每次失败时，控制器都会选择新的领导者，将当前的“领导者时代”加1，并与所有副本共享领导者时代。副本使用引导者时代作为验证当前引导者的一种方式。如果领导者失败并返回，则当它尝试联系其他副本时，它将发送它认为是当前领导者时代的信息。副本将忽略带有过时的领导者时代发送的消息。

该领导-划时代的检查点文件包含两列：时代和偏移，如图所示这里。每行都是最新记录的领导者纪元和领导者成为领导者时的最新偏移量的检查点。副本和领导者都包含此文件。它的作用是检查与哪个时期有关的偏移量范围。