00:00
好,接下来呢,我们就按照这张图当中描述的south China,以及进行相关的一个配置。好,把这张图呢,我定出来。那下面呢,我们来编写一下哈,打开。打开之后还记得写这个配置文件分几步了吗?首先,井号。呃,叫定义组件第一步。第二部叫配S。第三步。对的。配置。第四步。配置。Think。然后第五步。哎,叫拼接主件。知道吧,哎,这样呢,这五步一步步来编写,首先呢,这里面我们定义第一个啊agent就是A1。然后这里面它的S怎么配啊SOS啊,S4也就说可以配置多S,在这里面呢,我们就配置一个R1。
01:05
还有A一点,那下面它的穿丝an。山东四等于几个呢?配置一个好。再来一个,我们再配置一下它对应的think。克斯等于。K1。哎,先把这个组件啊,我们就定义好了,那接下来我们来配件S。那这里面这个S啊,它是卡夫卡S,那我们首先来看一下这个官方手册。点击这个documentation进来之后,第一个啊user guide进来之后呢,快速搜索一下对应的这个卡。好进来进来之后还是老规矩,看一下这里面标黑的字体是吧?哎,标黑的字体呢,正常情况下呢,我们都需要配置一下,那首先第一个呢是tap对吧?Tap,那我们把这个拿过来。RE。
02:02
然后第二说第一个这个穿丝是五,在拼接组件的时候进行拼接啊,哎,先配置一下这个temp叫T等于那temp选谁呢。看一下。Time是不是他呀?是这样吗?哎,把它配置好,那下一个参数。看一下是谁,下一个参数呢,是这个卡普卡boot serve4就说你要连接哪一个卡普卡集群。拿回来,拿来之后呢,把它。是不是这样写啊,哎,这样写,那这个我先给它干掉了哈,啊,那你这呢,就等于等于什么呢。Hi doop102,然后对应的9092对吗?哎,好,然后hi doop103对应的9092,那当然了,你还可以再来一个hi do104对应的9092。
03:01
OK吧?加那这呢是这个,哎,第二个参数的一个配置,那下面再往下找,下面还有一个卡普卡top个斯是吧,来把它拿过来。主要对应的这个呢,是配置的卡夫卡托斯。那卡瓦斯是什么含义呢?大家思考一下,因为我现在啊,这个是这是卡不卡,这是比如说flu呢,是消费卡不卡的数据,那你消费的是不卡的哪一个topic呢,那这块呢,哎,就是配置的这个topic啊好哎消费的是谁啊,哎消费的是这个toic啊topic是不是love呀,哎这个主题还记得吗?因为我们在之前创建的时候再找一下。在上一个辅助配置。当中。这块对吧,哎,这就是topic log,因为我这块创建的主题就是它啊,所以说后面我们这一集消费的时候仍然也是他好吧。那行,那这个呢也配置好了,那接着往下看,那它下面呢,还有一个黑色字体的,按理说这些是也应该配啊,那你看这块的描述是什么意思啊。
04:07
呃,说这个定义set ofs啊,Topics啊,The source subject on啊,The proper has higher property,也就说它的属性啊,要高于这个topics。And overright卡topic啊,如果你想配置它的话,那它是要高于这个的,那这是什么含义,是不是一个正者匹配啊,你说你可以匹配我消费多个卡法topic的时候,那你可以用这种方式。啊,进行一个匹配,那上面这个呢,哎,只是消费其中的某一个啊,这种top主题配置,那现在呢,我们就消费一个主题,所以说就用上面这一个啊,就能满足我们对应的一个需求啊就可以了哈,行,那这是这块,那接下来我们还要配一个谁呢。正常情况下,这里面必配项数就没了,哎,必配项没了,那下面你看这里面给出来你的案例。案例参考,案例参考当中啊,有一个谁呢?有一个这个。
05:02
叫size。啊,还有一个呢,叫Bach doriration millions,那这么两个参数,那这两个参数呢,我们也要给它配置一下,那什么含义啊,你这是卡不卡这是。哎,我来这里面消费。那问题就是我现在是从你卡发里面一次消费一条呢,我还是一次消费十条还是20条。那由谁来决定呢?还由这个BA size,你看这个BA size配置是5000,那相当于我一次从卡巴里面消费读取5000条。那好,那大家再思考一个问题哈,说如果卡夫卡当中它的数据量就没有5000条啊,假如说他只有1000条。那是不是始终达到达不了5000条,那我就消费不了数据的呢。哎,不是,那后面还有一个by million啥意思呢?即使你的条数没到,但是这个时间如果到了,那也可以。哎,你假如说你看这个BY,这个by million,它这个参数。
06:01
在上面这个位置啊。看到吗?哎,它对应的这个值啊,是毫秒值,比如说到达1000毫秒默认值啊,1000毫秒的时候,那我也可以主动的去哎拉取对应的数据。即使你这个条数没到也没关系。那这里面我把这两个值呢,都适当的这个放大了一些啊,一个呢是这个5000,另一个呢是2000。拿过来复制一下。对的这个参数。那好把这个关掉啊,这个也关了吧,那前面呢是A。那AGENT1,然后R1,然后后面我们消费的是BY是他啊。给它修改成5000。OK吧,那下一个参数这样。拉过来,然后是这个。等于我们得给它改成2000啊,2000毫秒啊。
07:00
OK吧,哎,这个呢,就是这个啊S相关的一个配置,那就这么简单,那所以说这个配置起来啊非常容易,那好,那还记得刚才我们这个截图这当中。还有一个谁呢?还有一个对应的拦截器。等于说这里面有个拦截器。那拦截器的时候是不是也得在这个SS里面进行一个配置啊好,那我们还是把之前的这个拦截器的配置找过来。叫in。INTERCEPTOR4前面呢,加上一个OK。这样呢,就找到了这个拦截器对应的配置,这我们在第一版那个配的时候是也配置过了,也就把这两个值是不是拿过来就可以了。那比如说这里面呢,我们把这个。直接拿来。哎,对应的拦截器IE source r1拦截器没问题,只不过呢,这里面我们用的是一个拦截器是吗?哎,一个拦截器,那把这干掉,然后呢,对应的是IE type,那这个tap后面这个拦截器是不是需要我们手动的进行一个自定义啊自定义啊。
08:06
那这个自定义呢,我们后续再给他补上啊。时间。戳拦截器,还记得这个拦截器解决什么问题的了吗?是不是解决零点漂移的问题啊?零点漂移啊,非常重要。
我来说两句