大家好,又见面了,我是你们的朋友全栈君。
1.测试ISR集合,新建topic,4个分区,3个副本
2.接下来,在一个机器上停止kafka,1机器上的副本全部被踢出ISR集合了
3.重启1机器,1机器上的副本又加入到了ISR集合了
4.查看消费者消费offset,这个offset保存在zookeeper中,我们可以通过提供的命令得到offset ./kafka-consumer-groups.sh –bootstrap-server centos-1:9092 –describe –group consumer1 ,解释箭头,第一个指的是topic分区,第二个消费都当前消费offset,第三个当前分区的offset,LAG代表还有多少消息没有被此消费都所消费。
5.写一个程序,四个消费者在同一个消费者组里面,消费者开始消费数据,可以看见,有4个消费都负责一个分区,LAG为0代表所有数据都被消费。
6.尝试三个消费消费数据。消费者1消费了两个分区。
7.broker leader测试,可知当前broker,leader是2这个节点,broker leader选举经过了4次
8.杀掉2这个节点,再来观察,broker leader变成1这个节点了,broker leader选举经过了5次
9.zookeeper中关键信息查看,brokers,分区信息
发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/129877.html原文链接:https://javaforall.cn
【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛
【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...