00:00
呃,那再往下呢,是要配置这个穿透选择器,为什么要配置这个穿透选择器呢。哎,你们学这个拆刀显示器的时候呢,嗯,就这块儿。显示器啊,正常情况你们学的时候应该是有一个replacing啊,还有一个mapplacing这么两种replacing呢,它会发往下一级所有的通道。对吧,啊发往下级输入通道,但是呢,这个marketpla型呢,它不一样啊呃,这从这往往下发哈,它会发网呢,哎,选择性发网,你想要通道,比如说这个这个K1这个传统呢,我想发往这个start通道,K2这个传道我想发往这个啊这个topic event里面去。啊是不一样的,我可以进行一个区分,那你想想区分的话,那你就得选择这个。这种方式啊。那如何来区分它发往哪一个呢?那你这块可以定义它的一个头啊,头头里面。我不知道大家这个知不知道这个组成哈,它组成里面是有这样几块。
01:02
放一边吧,啊,它是有body和头。Head也记一样啊,有header有爆点。啊,它有这么两部分组成,那body里面呢,存的都是这个数据啊,头呢,一般呢,我们可以用它来区分一些类型啊,我们从这个包底里面获取数据,判断出它是比如说是star类型。还是这个类型,判断完之后,我会把这些东西啊加到这个头里面去。啊,加到头里面打成标记,那你看我们这里面现在的这个标记呢,是什么呢?哎,我定义的这个头,这个头呢叫topic。我这块这个名字是可以随便起的哈,随便起的,那我起一个名字叫to啊,因为我是打到卡马布那之后,后面这个麦ing那就开始匹配了。如果你这个头这日后哈,我发现。
02:00
我怎么做呢?我发现这个包里这条数据它是start的,它包含start,我就会向这个头里面向。To里面添加。我添加什么呢?我添加这个topic啊,我添加这么一个标记。然后呢,如果我发现它是一本的。那我下这个topic。添加数据啊,我添加上这个。哎,我这样去做,我这样做完之后,那么它走到这个地方的时候,哎,找到对方中,它就会去找这个topic,看它这个值是多少啊,一发现啊,它的值是topic start,它就会发往传一,你说通道一,他如果发现这个topic呢,是这个topic event,它就会发往这个C2。
03:00
啊捋一下啊,它会你这块呢,我是要判断这个包底,往这个它对应的top的头里面去添加对应的值。啊,对应的值,那这个T里面它对应的就有两个值,比如说这个它可以取两个值分别是。TI。12。啊,处一下位置啊,这里面有两个值,另一个值呢是这个。啊,这么两个值。那至于是取哪一个啊,一发现这个头里呢,如果是存在start,那它就发往发往陈德一,那如果发现是这个topic和他就发网行。啊,这样一个过程哈,好。啊,那回来啊,回来之后那这块就简单了,那这块呢,就选择一个ma星,它可以选择性发网。啊topic topic搞定,那这个topic也搞定了,那下面呢,就剩下这个谁的呢,就剩下这个卡法诺了,也就说前面这个已经配置好了,他已经配置好了,他已经配置好了,这个一会我们还在没在写呢,一会儿具体去写它。
04:14
那下面呢,说一下这个卡帕田总。那卡布才东西怎么配啊?所有的配法呢?都是按照官网去来就行了。看吧,看到看看这个案例是不是啊。对,诶卡不卡S,嗯。这个不是啊,继续往下找。这个呢?哎,这呢,看看哎,找到了这个卡不卡传头相关的配置信息啊,下面呢,给你一堆描述对吧?啊一堆描述这些呢,你这个英文看不懂没关系啊,直奔主题啊,直奔主题,主题在哪呢?主题在这呢。
05:03
就看它相应的这个给你的案例嘛,对吧,看一个张斯啊,这也是官方案例啊,比较清楚,那首先呢,第一个呢,是这个类型,你要定义成呃,Org阿帕奇姆卡普卡卡。那你看咱们怎么配的?咱们配置的也是这个,嗯,这个A1穿斯啊c type,它的类型呢是org阿帕奇China卡布卡卡布卡。对吧,啊一样的,然后呢,后面呢,又配置了一个卡夫卡啊boot service。那你看他这个喷谁呢?这个是卡夫卡不的service对应着卡夫卡一,然后9092 9092,这不就是broke吗?相当于是卡夫卡的每台服务器,服务器节点呢。对吧,那我们的服务器节点这个主机,这个主机名称可不是它呀,我们对应的主机名称不就是开102,开103开104。是这样吗?哎,就这么简单啊,就这简,那下一个呢,是这个,你这个数据要发往卡夫卡的哪一个topic里面去,这个名称怎么起,那我这里面起的是topic star,那另一个呢,写的是topic event。
06:09
可以看到官网。呃,它这里面没配这个具体这个topic啊,那咱这个呢,需要配置一下看这这不吗?啊,又是这个卡哪一个往哪一个里面去写哈,你说你这里面它提上面这些参数呢,你可以去看。啊,这里面是最全的啊,最全的他案例呢,是给你准备了一个最小系统啊,最小的啊能够应用的。好,那回来,那这里面我们分别指向的是,呃,这个topic start和。然后后面还有一个呢,就是肯格化ID啊,其实是定义了一个消费者主啊,消费主它俩是不是一组的,那我这里面呢,定义的是一个消费者主哈。对吧,你看格数ID嘛。那这里面我们就放到了这个consumer consumer这个消费者组里面了啊,咱俩名称一致。OK,那这里面唯一还有一个参数没解释,就是它。
07:00
啊,就是他,那他你看一下这个含义哈。嗯,找官网。Hier default。这个吧,啊,就是它哈,就是它就是pass as event,你再确认一下pass as from event对吧,那这个是什么意思呢?它默认的给你的是true。啊,一定不要用它这个处哈,一定不要用那个处。你看。嗯,这里面说了一大堆含义啊,Exceptallo with,这个from event,这个结构in the channel啊,This should be true if flu south is writing to the China and force is other produce are writing into the topic a that channel is using a from south message to kaka can be passed。什么?啊,这么一大堆哈,看起来这个挺晦涩的啊啊,一般情况下你可以这样去测试一下,如果你不改这个值。啊,不改这个值,那它前面呢,都会给你加上一个弗鲁姆基本的这个前缀。
08:02
啊,当然这个不是我们想要的啊,但是你发现有这个问题之后呢,你可以把它直接改成false,你就像我这种。直接支成fo,那支成他就OK了哈,就会把它干掉,那行,那这个呢,其实就是具体这个配置哈,以后呢,也是你们去,呃,企业开发的时候,如果出现了一些新的这个source啊,Channel think啊,一定第一时间查官网,查官网啊,官网是呃最好的这个学习途径啊,按照它去配置就行了,那这样呢,我们把它拿过来哈,把这个配置文件放里面去。嗯,放到炕下吧。CD。好,T毛总。进到这个里面里面呢,我给它放到这个目录下就得了哈,因为我这里的配置文件比较少啊,比较少,我就直接在里面创建一个。呃,创建这个文件呢,一般呢,建议你们去建名之意哈,比如说你这个读的文件读的是什么,比如说我读的是一个文件啊,或者说你读的是一个日志,你写一个log也行啊,都可以哈,然后中间这块呢,我是flu对吧?啊然后呢,它这个数据去了哪呢?告诉他卡不卡,比如说数据源在哪。
09:18
啊,中间干了什么事,最终去了哪,这样去起名字相对来说就会好一些啊只是com配置文件,OK,那在这个配置文件里面呢,我们需要配置它对应的这个。呃,South和China就行了,因为是south呢,是泰阳DR south China的话是这个,呃,KA法的两个channel啊,卡瓦哈。OK,这样就搞定了啊,正常情况就OK了哈,OK的话呢,这个配置文件呢,你还要分发一下,因为不光在这个102上用,103是不是要用对吧,但是104是不用啊,104不用你可以把它删掉。呃,同步一下syn c OK。
10:01
同步分发好搞定,那这个搞定回来之后。嗯,下面呢,你要记住哈,你这个拦截器还没写呢。你记住了,你这里面用到了一个是ETF拦截器,还有一个是这个分类型拦截器并没有用的啊,你现在是启动不了的哈,别着急啊,别着急,那下面这个呢,是这个播放这个PD啊。嗯。我就不播了啊,因为我这个上课已经讲了,每个是什么样的一个含义。看一眼吧。稍微看一眼啊。啊,比如说呢,这是正常配置完了啊,配置完的你可要捋一下啊,基本上这个组成结构就是写这个from嘛,先写主件对吧,你是agent agent,你这不是agent吗?这A1啊,这个起一个agent名称,那之后呢,这个agent里面有这个south,有China,还有think,那我们这里面特殊啊,没有think,只有China。啊,那就是R1C1C2啊定义好定义好之后剩下的就是太阳DRR啊配置拦截器配置啊选择器配置,还有呢,下面的这个是什么卡卡配置。
11:12
那来一下含义吧,你像这个TDR,那这个就是指定那个TDRR的方式器读取文件,那这个呢是记录这个呃,日志读取的位置啊,这个呢是这个啊,这个是索引的位置哈,这个相当于是这个日是正常的位置。这里面定义的E截器类截。这个是根据日志类型区分,否则的话默认你要不配置这个的话,默认的是这个replacing啊。呃,再往下呢,是这个日志呢,会发往啊自己想要的这个通道啊,根据它呢去识别一个配置,OK就没了啊很简单啊。
我来说两句