从本质上来讲,Kafka 基于“复制机制”保证数据的一致性,涉及
- Partition,每个Topic分为多个分区,每个分区都有一个唯一的标识 Partition ID
- Replica,每个Partition在不同的机器上可以有多个Replica,一个Replica是Leader,其他的是Follower。 Leader 负责处理所有的读写请求,而 Follower 则负责从领导者那里同步数据
3.ISR, ISR是一组与领导者同步的副本。 只有 ISR 中的副本才能被选为领导者。 如果副本不能及时从领导者同步数据,它将被从 ISR 中移除。 - 消息机制,在进行消息的提交、确认策略时所采取的相关措施等。
当然,还有日志等层面