三、Kafka副本

news2025/10/31 14:23:32

2、创建2个分区两个副本

/usr/local/kafka/bin# ./kafka-topics.sh --bootstrap-server 192.168.58.130:9092 --create --topic atguigu2 --partitions 2 --replication-factor 2

在这里插入图片描述
3、查看topic详细信息

/usr/local/kafka/bin# ./kafka-topics.sh --bootstrap-server 192.168.58.130:9092 --describe --topic atguigu2

在这里插入图片描述

在这里插入图片描述
Leader是接收生产者的数据，会先收到数据，所有Follower中的数据都是从Leader中拉取的，由于存在时间差的问题，导致Leader中的数据要多一些，Follower中的数据要少一些。
ISR[0 1 2]:
表示三台服务器正常运行

在这里插入图片描述
LEO(Log End Offset)：每个副本的最后一个offset，LEO其实就是最新的offset+1。
HW(High Watermark)：所有副本中最小的LEO。

（1）Follower发生故障后会被临时剔出ISR。
（2）这个期间Leader和Follower继续接收数据，那么对应的HW和LEO就会正常的变化。
在这里插入图片描述
此时接受数据 8 9
HW=8
LWO=9+1

（3）待该Follower恢复后，Follower会读取本地磁盘记录的上次的HW，并将log文件高于HW的部分截取掉，从HW开始向Leader进行同步。

（4）等该Follower的LEO大于等于该Partition的HW，即Follower追上Leader之后，就可以重新加入ISR了。
在这里插入图片描述

（1）Leader发生故障之后，会从ISR中选出一个新的Leader
（2）为保证多个副本之间的数据一致性，其余的Follower会先将各自的log文件高于HW的部分截掉，然后从新的Leader同步数据。
注意：这只能保证副本之间的数据一致性，并不能保证数据不丢失或者不重复

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/2054334.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！