00:00
呃,给大家讲几个这个脚本啊,那之前咱们呃讲过了,已经用过了这个这俩这俩就一个生产的一个消费者对不对,那还有什么呀?呃,还有咱们那个这个什么启动啊,呃,这个创建topic的脚本对不对,还有这个启动和停止脚本,对对吧,咱们呃讲过这几个啊,然后在其实这里边其实还有一个比较重要的啊,也是咱们那个监控软件当中就是都有的一个内容啊,咱们内容其实就是这个啊,叫做卡不卡consumer groups.sh,这也可以用来查看什么呢?可以查看咱们目前这个集训当中就是,哎,正在就是消费咱们这个数据的一些消费者组的信息啊,大家还能想起来吗?你那个卡不卡监控软件上能看到什么呀?哎,能看到咱们集群当中现在有哪几个消费者组,哎,能看到他们正在消费的这个,哎,Topic对不对,能看到这个每个消费者啊,他消费的分区是哪个,哎目前消费到哪个offet了。
01:00
是不是能看到这些信息啊,对吧,但这些信息实际上没必要用那个监控软件去看,你用这个脚本也能看啊,也能看啊,这个脚本怎么用呢?我们来看一下啊,咱们直接比如说我现在想看一下咱们现在集群当中这个消费者组的信息啊,这里边咱是不是开着一个消费者的呀?啊,那接下来咱们看一下啊,咱们就直接点杠啊,这个卡不卡哎,Consumer啊,groups.sh,然后后边呢,我们需要指定一个卡夫卡集群地址BOO啊,然后TP serve啊,然后呢,后边还是102冒号9092,然后边呢,你可以杠杠,呃,9092啊九二,然后杠杠list。例子之后,你能看到咱们这个目前集群当中正在消费信息的消费者组的ID,这是消费者组ID啊,那这个ID呢,咱们是不是在启消费者的时候并没有指定啊,对不对,这是它随机生成的一个可入ID啊,而且这个ID呢,你每次启动这个cons consumer它都会怎么样啊,都会变啊,每次都是一个新的组啊,新的组啊,这是他一个ID,那现在假如我想看一看这个消费者组,它里边的消费者的信息呢?那怎么看呀?
02:07
怎么看,那是不是就是de describe呀,对不对,那后边呢,我们指备一个啊up group把这个ID是不是拿过来就行,那你回车。回来之后呢,你就能看到诶这个消费者组里边的这个消息,这个信息,但是这个字太大了,对吧,咱们显示的不好看,我把这个字调小一点啊,我这调成这个十啊,调成十诶太小了啊呃调我感觉调成这个11应该就行啊,十一来那咱们再来重新那个看一下来回车。呃,这个还是还是有点难看啊,来咱们给给给给粘出来对吧,可以粘出来看一下啊。我们来一个新的文件啊,CTRLV啊。还是不好看啊。行,这样应该就就还凑合了啊,这样还凑合,大家能看懂能看清吗?不太好清,不太好看出来啊来看一下前面这个第一列是什么信息啊,是他那个组织ID对吧?啊然后这个是什么?是他消费的topic对不对,那后边是什么呀?哎,他消费的这个分区啊,因为first有三个分区对吧?零分区,一分区二分区,那后边这个是什么呢。
03:19
啊,应该是啥呀,咱们这里边其实是有相应的这个标头标题的啊,应该是有一个什么,有一个什么current of outside啊,然后有一个什么load end outside啊,还有一个leg,就是那个消费的延迟,对不对啊是这样的,这是不是咱们在之前大家用那个监控软件的时候,是不是也能展示这些信息啊,就都都都来自于这儿啊,都来这,那后边呢,是什么,是他那个呃,消费者消费者的信息对不对,我们现在这个消费者组里边有几个消费者呀。是不是只有一个消费者,咱们这个组里边,我是不是只取了一个消费者,只有一个,那所以说你看这三个分区是不是都有这同一个消费者消费啊,哎,这是目前咱们这个消费的情况啊,其实就是这些东西啊,就是这些东西啊,这玩意儿呢,其实大家呃,这个不用监控软件也能看到啊,所以就是大家以后如果说到公司之后呢,你有这个监控软件啊,那你用这个装用那个看,那没有的话,你要需要去看的话,可以用这些脚本去看啊,也也就是你在监控软件上实现的功能,它肯定都不是他这个凭空捏造的,对吧,这里边都有啊,都有来我还调回去啊,调成这个14啊,行,这又补充了一个脚本。
04:30
啊,然后这里边儿还有俩比较重要的脚本给大家看一下啊,哪两个呢,来看一下啊,就是这个。卡夫卡producer performance test,这是什么东西,这是不是咱们卡夫卡里边生产者的性能performance就是性能测试的一个工具,对吧?那除此之外呢,还有一个叫做卡夫卡consumer performance test,消费者性能测试的一个这样的脚本啊,也就是其实说白了生产者测试测的就是啥。
05:02
啊,就是写性能,那消费者测的就是啥呀啊,就是读性能呗,就是跟咱们H那个IO是不是一样啊,就是测它的读写性能的啊啊那咱接下来呢,就把这个呃读写测试,咱们来测一下啊。
我来说两句