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

Question

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

Answer 1

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

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