提问者已获得满意解答
查看其它 2 个回答HelloWorDomain的回答
- Kafka 通过 副本机制 来保证数据的可靠性和一致性，每个分区都有一个 Leader 副本 和多个 Follower 副本 ，生产者和消费者只与 Leader 副本交互，Follower 副本从 Leader 副本同步数据。
- Kafka 使用 高水位（HW） 和 日志末端位移（LEO） 两个重要属性来定义消息的可见性和同步状态，HW 是指消费者能够看到的最大位移值，LEO 是指副本写入下一条消息的位移值。
- Kafka 在每次副本领导权发生变更时，都会增加一个单调递增的版本号，称为 Leader Epoch ，它用来规避因高水位更新错配导致的数据不一致问题。
- Kafka 的一致性保证是基于一个假设： ISR（In-Sync Replicas）列表中的副本都是同步的 ，ISR 列表是指与 Leader 副本保持同步的副本集合，只有 ISR 列表中的副本才有资格成为新的 Leader。