如果Kafka副本follower出现故障,那么Kafka是如何处理这些故障的呢?

如果Kafka副本的follower出现故障,Kafka会进行以下处理:

  1. 临时踢出ISR:follower故障后会被临时踢出ISR,待该follower恢复后,follower会读取本地磁盘记录的上次的HW,并将log文件高于HW的部分截取掉(HW之前每个节点都有,故安全),从HW开始向leader进行同步。
  2. 数据同步:等该follower的LEO大于等于该分区的HW,即follower追上leader之后,就可以重新加入ISR了。

这样就能保证Kafka的副本之间数据的一致性了。

发表评论

后才能评论