温馨提示:文本由机器自动转译,部分词句存在误差,以视频为准
00:00
好,接下来呢,我们来看一下消费者主对应的案例需求什么呢?测试同一个主题应的分区数据,诶,同一个主题对应的分区数据只能由消费者主当中的一个消费者进行消费,比如说这个分区数据只能由这个消费者消费,不能由两个消费者同时去消费某一个分区的数据。来来验证这件事啊,那下面呢,我们要搭建的就是创建三个消费者,并让他们组成一个test的消费者组,然后呢,来消费force的主题的数据,看到的现象就是他消费零,他消费一,他消费二啊这样一个结果。那怎么做呢?哎,这个代码呢,非常简单啊,之前我们写过对应的这个消费者代码,对吧,哎,CTRLCCTRLV,然后加一个一。哎,这就来了啊,这就来了,然后再来一份CTRLCCTRLV。来一个二好。那为什么我现在创建这么三个消费者,他们就是一个主的呢?
01:04
看一下这个地方。还记得是它吗?也就是说他们的消费者主ID啊,都是test,那么他们就会自动的形成一个主,那是不是我说的这样呢,我们把它运行起来哈,右键执行。再来看第二个。执行。第三个。执行。这个清空的啊。好,现在三个消费者我都已经启动完毕了。那么下面呢,我开始往这个first主题里面发送数据,那我用哪一个发呢?啊,我用这个带call back这个发送啊call back我检查一下代码有没有自定义的。分区器没有没问题,那下面我往for主题发送出去,这个五条啊,有点太少了,哎,我发送500条,同时呢,我在这里面发送的过程当中,我加一个延迟。
02:07
帅点sleep。啊,加一个延迟之后,尽量呢,让这500条数据啊,发送到不同的分区里面去。行,那我们先做一下啊,右键之晶。看一下哎,我发送的数据当中,有发往零号分区的,有发往一号分区的,也有发往二号分区的,那我就检查一下消费者里面他是怎么消费的。看第一个消费者,你会看到第一个消费者消费的数据是不是都是零号分区的数据啊,哎,都在这一排啊看往上看。是不都是零。对吧,那接下来我看这个好可星猫一看秀猫一,你看一下这里面消费的数据是不是都是这个分区二的一个数据啊,啊,你千万不要以为说我这个写的是一,那他就应该消费的是一号分区啊,跟这个名字没有任何关系,它在底层会自动的把你这个消费者啊进行一个编号,OK吧?啊这要注意啊,那他消费的是二号分局的数据。
03:07
那下面呢,来看这个H2,你看它消费的就是分区一对应的数据。上周。对吧,哎,你会发现啊,一个分区的数据不会有两个消费者进行一个消费啊,这就是消费者主啊对应的一个注意事项哈。
我来说两句