00:00
好,那做一个测试啊,最重要的呢,就是我们要开启一个消费者对吧,开启一个消费者,嗯,消费者呢,这个在这。拿回来。这边有的东西我给它关掉啊,没有必要对吧。好,我们看一下。这边呢,我的z cable跟卡普卡呢,还是开的啊,所以呢,我们直接把这个粘过来,然后叫ods。Base DB对吧,消费这个主题的数据,好,那接下来呢,我就打开我的ods层的一个代码。这边我们等待它打印那个连接到最新的日志,对吧,最新的blog啊,它会打印这个日志出来。
01:09
诶连到最新的,那我们就做一个测试对吧?呃,那首先我们还是拿这个base trademark啊加一条数据12。这边呢,还硅谷也行,这边呢有数据,更重要看卡夫卡,卡夫卡数据是不是也过来了。对吧,啊,这是卡发数据啊好,那接下来呢,我们不用这张表,因为我们当前监控的是不是所有的表啊,那我把这个删掉啊,把它删掉。好,删掉之后呢,这边也会有一个删除数据没有问题对吧?呃,那接下来呢,我就随便再挑一张表,假如说payment的衣可以吧,Payment呢,我们切到这个最后,然后呢,再添加一条数据1769。二对吧,好,这个呢,是一个随便的一个号码,那就这样呗,差不多对吧,然后呢,这个是一个订单号,那我们也2644826448啊啊U的ID给个4000,呃,Payment的TYPEB1102呗,随便后面我就不写了,OK吧啊都一样的,后面不就不写了,都是none值卖保存,那这是另外一张表啊,Payment in for这张表来看这也过来了吧,它的表明是payment in for,因为我这一次呢没有加表明,表示所有的数据都会先听到,然后呢,实时的传到卡夫卡里边啊,那这一块截止到这块为止,咱们的行为数据跟业务数据采集就全部搞定了啊。
02:39
对吧,我们的行为数据跟业务数据的采集就全部都搞定了啊,但是这里面有一个点我需要去加一下,就是防止未来大家在生产环境当中丢了什么点呢?呃,之前我们写的福利CDC这啊。我把这个给大家写上啊,但是呢,我会注释掉啊,我把这个所有的代码后面呢,所有代码当中,我都会把这个给大家加上。
03:10
设置CK啊,按状态后端。对吧,但是呢,未来我会把这个都注释掉。啊,我会注释掉。就是告诉大家,因为我们自己做测试嘛,没必要对吧,因为我们测了一个就够了啊,没必要每一个都去测,因为每一个都测的话,每一次你测任何东西都要把HD再打开,没必要麻烦一点,对吧,所以呢,没必要,但是我把这个放在这儿告诉大家,未来你到了生长环境当中,写代码的时候,这些东西一定是要有的啊,一定是要有的,只不过说呢,我们他问了就不不开HDFS了,对吧,要不然还要开HDFS啊,是这个意思啊好,这是我们所看到的这样一个现象,也就是说最终呢,我们把数据测通了,同时我们在这还打印的数据,对吧,防止后面我们看诶卡夫卡没有数据,那我们可以看一下这有没有数据啊,来对比他们俩互相做一个验证,对吧,打印这个都要啊OK,这是我们这个内容就搞定。
04:20
也就是说到现在为止,我们第一个文档里面所有的东西全部都搞定了啊,包括附录里边,本来可能是需要大家自己去看的,但是课堂上的我都讲了一下,然后同时做了对比,你要把这个对比的内容要记得住。就是他对吧,所有的东西我在课堂上都去讲了一下。
我来说两句