更新时间:2023年06月15日17时18分 来源:传智教育 浏览次数:
Kafka的服务器端由被称为Broker的服务进程构成,即一个Kafka集群由多个Broker组成。这样如果集群中某一台机器宕机,其他机器上的Broker也依然能够对外提供服务。这其实就是Kafka提供高可用的手段之一。
Kafka中可以将消息备份,备份的过程又可以叫做保存副本(Replica),领导者副本(Leader Replica)和追随者副本(Follower Replica),从而保证系统的稳定性。下面看Kafka的备份机制。
同步方式备份需要同步复制保存的follower,如果leader失效后,需要选出新的leader,选举的原则如下:
第一:选举时优先从ISR中选定,因为这个列表中follower的数据是与leader同步的。
第二:如果ISR列表中的follower都不行了,就只能从其他follower中选取。
极端情况,就是所有副本都失效了,这时有两种方案。
第一:等待ISR中的一个活过来,选为Leader,数据可靠,但活过来的时间不确定。
第二:选择第一个活过来的Replication,不一定是ISR中的,选为leader,以最快速度恢复可用性,但数据不一定完整。