kafka 集群测试

kafka 集群测试1.ISR集合2.消费者3.brokersleader4.zookeeper

大家好,又见面了,我是你们的朋友全栈君。

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账号...

(0)


相关推荐

  • Java是什么软件-详细解答Java到底是什么「建议收藏」

    Java是什么软件-详细解答Java到底是什么「建议收藏」许多想要接触计算机编程的朋友对于开发语言没有一个系统性的概念,会问出类似于Java是什么软件?这类问题,实际上我们通常不把Java定义为软件,那么Java到底是什么?Java开发用什么软件?请容我细细道来。

  • spring拦截器和过滤器有什么区别_拦截器和过滤器的区别面试

    spring拦截器和过滤器有什么区别_拦截器和过滤器的区别面试简介这几天在回顾Spring的AOP时,对过滤器,拦截器,AOP的关系有点好奇,故记录做以备份。在实现一些公共逻辑的时候,很多功能通过过滤器,拦截器,AOP都能实现,但是不同的方式有不同的效率。具体有什么区别,看下文描述。前后端交互基本逻辑过滤器过滤器拦截的是URLSpring中自定义过滤器(Filter)一般只有一个方法,返回值是void,当请求到达web容器时,会探测当…

  • CreateFileMapping 函数「建议收藏」

     原文:http://dev.csdn.net/develop/article/69/69323.shtm内存映射API函数CreateFileMapping创建一个有名的共享内存:HANDLECreateFileMapping(HANDLEhFile,                                                                    

  • appium–真机测试app「建议收藏」

    appium–真机测试app「建议收藏」1.appium设置启动appium,host和port默认即可,在EditConfiguration中将AndroidSDK和JavaJDK加到环境变量中。设置好后保存并重启Appium

  • C++ sort()排序详解

    C++ sort()排序详解本文对C++中的sort()做了一个比较详细的说明,包括为什么选择使用sort()、sort()函数的实现原理、sort()的使用方法等等。

  • hi3516dv300 sdk_Hi3516DV300

    hi3516dv300 sdk_Hi3516DV300Hi3516DV300编译环境搭建问题及解决1.安装完工具链,提示找不到gcc问题:bash:/opt/hisi-linux/x86-arm/arm-hisiv300-linux/target/bin/arm-hisiv300-linux-gcc:没有那个文件或目录。安装完工具链,提示找不到gcc,但实际gcc工具已经安装上是由于开发环境是32位的,而当前的ubuntu是64位的解…

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号