温馨提示:文本由机器自动转译,部分词句存在误差,以视频为准
00:00
好,那接下来我们看第二种模式叫卡夫卡模式啊,因为刚才我们在第一次看这个配置文件的时候,发现它里边有一个so mode,它默认的呢是TCP,这个时候呢,我们就可以把它改为卡夫卡,可以让它直接发送到卡夫卡,而这个时候呢,并不需要我们去写代码了,看上去更方便一点,对不对,好,那我们修改一下啊呃,同时呢,你要发送到卡夫卡,你得指定一下卡夫卡的集群信息,对吧?好,这两块呢,我们同时来做一个修改,此时呢,我们修改配置文件,所以肯定会涉及到重启,呃,先呢,我把这个canel去关一下啊,等会儿呢重启啊,呃,那此时呢,我们还是进到这个C里边去修改canal.pro啊为。呃,此时呢,首先第一个位置修改我们的模式为卡夫卡啊,因为之前默认的呢是TCP,这个时候呢,把它修改为卡夫卡。啊,第二个位置就是说卡夫卡呢,当前集群的信息我们也要做一次修改,对吧?呃,那这个在哪呢?在底下啊,它会有一个最后一块,它会关于MQ的配置信息,那么主要改的就是这个啊下面呢,是卡夫卡有关当前MQ的生产者的相关的参数啊呃,那这边呢,我们配的是呃卡夫卡,卡夫卡呢,我配的是102冒号9092端口号啊哈杜普103冒号9092以及哈杜104啊然后呢,9092我搭的是一个卡夫卡的集群保存退出。
01:33
啊,那这块呢,我们已经把卡夫卡的这个东西搞定了。啊,就是说它的服务,但是对于卡而言,你这个数据发送到卡夫卡,卡夫卡呢,我们知道它里边是有topic主题的,所以呢,我们还得指定一下,你到底要将这个数据发送到哪一个主题,对吧?那这个在我们的example这个instance.pro里边去配的啊呃,看一下instance,哎,不是cat,我们直接为去修改了啊。
02:02
呃,那这个在哪呢?往下翻,诶就在这儿,它用到的一个主题叫example啊,当然我们可以改啊,呃,比方说我们用canal。Test啊,我往这个主题里边去发OK吧,呃,当然你卡夫卡的主题呢,是默认可以被创建的啊,所以你就不用关心了啊,当然你可以提前去创建一下,呃,在这个配置文件最后呢,我们大家看一下啊,它可以配置一个什么东西呢?就是说当前这个。你要发送到哪个分区啊,如果说你是多个分区,那么你要这样配。它number,然后呢,你去指定一个数据库里面的表的主键。啊,或者说随便指定一个列作为他哈希往这个里面去放啊,当然我们现在主题只有一个,我们就不做这个测试了啊,保存退出就好了,呃,那么此时呢,这个就搞定,配置就搞定了,搞定之后呢,我们把这个肯定要重新启动一下啊并。然后呢叫startup点啊这个呢,GPS看一下它已经启动了。
我来说两句