00:00
好,那接下来呢,我们做一个测试啊,这个时候呢,直接往卡夫卡发,所以呢,我要启动这个ZK和这个卡夫卡了,因为卡夫卡它目前呢还是依赖于这个cable的,对吧,Start。当然这个东西是我自己写的脚本啊,写的脚本啊,群体脚本,这个比较简单,只要你会单节点启动,呃,或者说给大家看一下吧啊呃,大家有兴趣可以截个图自己看一下啊呃,ZK,然后这里边呢,我们就是正常的一个脚本,然后case到了一,到了一呢,就看到我们在这后面写的stop stop对吧,然后如果是start,那循环三台机器,然后里边呢,执行ZK的start就好了。对吧?好,停止一样的执行stop,然后也可以查看它状态status啊,就是写了一个循环的脚本,包括这个卡夫卡的脚本一样啊,在这儿也是获取到了一,如果你是stop,那我们启动这个stop,然后如果你是stop,那启动stop,执行这个stop脚本就好了啊,就是一个循环的脚本,这样呢会方便一点,因为像ZK和卡夫卡呢,这两个框架在官方的病例当中,它并没有提供这个群体的命令,所以呢,我们就自己写了一下啊,那切回到我们的卡夫卡里面来,因为我们的canel已经开启了,对吧?所以呢,做测试的时候,我在插入数据之前,我先得启动一个消费者,对吧,好B。
01:26
叫卡夫卡。Consumer啊,刚刚我的。港so。啊,10229092,然后呢,要写一下我们监控的主题,刚才我写的是canel下划线。Test好回车,诶监控这个主题,呃,那么此时呢,他告诉我们他并没有创建这个内容,那这个没有关系,对吧,因为我们没有数据过来啊,没有数据过来,好,那接下来呢,我们往里边插入一张数据,比方说还是先插入这个张三。
02:01
变形啊,这个地方呢,又会多一个张三啊,你看又多了一个张三,那接下来呢,我们看这边好,此时呢,张三数据就看到了,在这。如果自己封装类型会多一点,那我们看看基本的啊,呃,有这个数据库。对吧,然后还有这个表明叫user info,它的操作时间,然后呢,类型insert,然后就是数据。数据本身对吧,Data。好,这是这个,呃,这是新增数据,然后我们修改一条数据,把这个周三呢,我们变一下变成周六吧,比方说啊,然后呢。保存,保存好以后呢,我们来看一下。这个是一个修改的数据,好,那看数据本身是照6MAIL,然后呢,由于是修改的啊,它类型呢是update,但是old呢是name等于张三。对吧,Name等于张三,OK,呃,这个说明它这个修改的数据,它会有这个O的数据啊好,那我们在删除一条数据给大家演示一下。
03:02
走,删除掉这个照六,诶,那这这边呢,我们来看一下这个数据啊,这条这一条呢来看。它呢是照六这条数据本身data,然后类型呢是delete,那我们就知道这个数据呢被删除掉了,其实我们自己在封装的时候,我用的是before加after这种方式可能看得更清楚一点,那这个地方当前这个data里边到底是新增的更新的还是删除的,是不是我们要提必须要结合这个类型来看呢?对吧,如果我们自己封装的,我就可以不看类型,我也知道当前这条数据到底是新增修改还是删除。对吧,好,那更关键的不是这个点,我还要给大家测试一下,刚才我们看到在我们操作数据的时候,是不是可以单条数据啊,就单个S影响多多行数据啊,对吧,那此时呢,我再来我还是执行这个命令。同时插入两条数据啊。保存,那这边呢,又会多两条,张三和李四没有问题吧,那来看一下,注意他此时只有一条数据。
04:05
他这个得塔呢,看它是一个。杰森数组。诶,它把两条数据呢,放在一起的,这个跟封装的格式有关系,对吧,因为它里边呢,封装的是叫entry,一个entry呢,可能包含多条数据,其实如果我们用这种方式的话,未来操作的时候不方便,因为我们需要把这个数据给它炸裂开,未来我们做数据分析的时候,肯定要单行数据处理吧,我们不能对一整行的S做处理,对吧,所以呢,我们还要多做一个。压屏操作,把这一行数据呢,变成两行数据对吧?好,他其实用这个卡夫卡直接的模式呢,可能还稍微的麻烦一点,对吧,就是你要多做一步这个操作啊好,那这个呢,是我们演示的卡夫卡直接发送到卡夫卡里边的。
我来说两句