00:00
好,上节课啊,我们这个卡不卡启动停止脚本已经写完了,那接下来我们做什么事呢?哎,还是看一下这个地图,这个地图当中啊,哎,卡普卡已经安装完了。但是这个通道我们目前还没打通。对吧?哎,我们需要产生日志,采集日志,然后把数据发送到对应的考卡。哎,那怎么能证明这个数据到没到这个行法呢?我们是不是就可以在这个卡夫卡里面写一个卡夫卡的消费者。对吧,哎,产生一个消费者一直在这消费,然后这边一直生产。啊,这样一项过程,那行,那现在我们来做一个什么事呢?哎,来到这儿啊。这里面是给大家提供了相关的查看topic卡topic,创建卡topic和呃删除卡topic啊对应的API还有卡的生产者消费者API。哎,方便大家去进行一个测试的啊,其实咱们之前在讲卡夫卡的时候啊,课上已经都讲过了,那这里面我就不再赘述了,那首先来看一下,第一个说查看卡夫卡topic。
01:05
这命令人说这个卡普卡你也没创建呢。对吧,我们是不是没创立过海巴塔哥,那它有没有。你说那肯定没有。看一下呗,看下到底有没有C,不行还是没有。正。见证奇迹的时候要到了啊,发现什么?哎,发现这里面有两个对应的topic,分别是topic start和一本。那时候我没创建呢。记住哈,那你看一下这个架构图。这块。里面有一个分类型拦截器,它会把接收到的日志分别发往自己指定的通道,启动日志发往启动topic,事件日志发往事件的topic。哎,那弗在发的过程当中,如果发现卡卡里面没有对应的topic皮克。
02:03
他会做什么事?他会给创建。哎,就会在这个卡吧里面向里面写说我要创建一个topic star topic。哎,是这样一套流程,所以说哎这块你不创建,它会自动的给你产生啊行,那看一看这个通道有没有打通,我们需要做一个什么事呢?首先来到这个卡卡消费者,这我们启动一个卡瓦消费者,这是from beginning哈,从头开始消费,先消费一下top star看有没有。来。到这儿请。目前主设在这儿啊,对吧,数据来了什么时候来的,哎,是我们之前在生成日志的时候在哪里啊,在这里面。CD time,哎,这里面有对应的日志数据。哎,这里面有日志数据是之前产生的是吧?啊,一会我们在线成生成一下啊,别着急。
03:07
现在呢,这个是消费启动日志,那我们再创建一个。我再来一个,这是启动日志的,我看一下这个事件日志有没有。我把它拿过来,我这次啊,这个topic我改一下,改成谁呢。改成这个。拿过来。再来执行一下。这。两个通道你都得去测试啊,不能只测一个。对吧,哎,这个也有相应的数据。那这个就能证明这个通道是好的吗?哎,暂时还不能啊,暂时还不能,现在呢,这是历史的数据,因为我们执行的命令啊,是from beginning对吧?哎,From beginning。
04:07
行,那在这之后我们来执行一下。二杠号删掉,删掉之后呢,我们执行一下这个log对吧,行轴。看一下。哎,这个102的两个topic都消费到对应的数据。啊,屏幕在快速的闪烁,这就说明目前这个通道已经打通了,相当于我们前面做的这些工作。日志商场flow卡不卡以及主K包安装全部都是OK的,那接下来我们要做的是这块呗,对吧,好。
我来说两句