大家好，又见面了，我是你们的朋友全栈君。
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,分区信息
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请联系我们举报，一经查实，本站将立刻删除。
发布者：全栈程序员-站长，转载请注明出处：https://javaforall.net/129878.html原文链接：https://javaforall.net
![springboot线程池的配置使用[通俗易懂]](https://javaforall.net/wp-content/uploads/2020/11/2020110817443450-480x300.jpg)
