00:00
好,上节课我们是讲了,作为生产者把数据呢发送到了卡法机群,那接下来呢,我们来演示另一个案例,就说呢,为消费者来消费卡普卡对应的数据,也就说上节课呢,我们是把这部分数据搞定了,那接下来呢,我们把后半节搞定。那后半截呢,我们仍然是需要一个,然后呢,把消费到的数据打印到控制台。这样一套流程,那好,那下面我这个应该怎么配置呢。既然我这个左侧这边呢,是从卡夫卡里面拿数据,那他的S必然是卡马S。Channel呢?哎,这里面仍然传输的日志,不追求可靠性,追求效率,我们仍然选择memory好。那未来我数据打印到空台,我直接配置一个log s就可以了。哎,这样一套流程哈,好,那下面呢,我们就来写一下对应的这个配置文件啊,那这个配置文件呢,我们仍然是放到这个flu job下啊。退出来。
01:01
进入到目录。这里面呢,有一个job斯。哎,上节课我们写的是这个配置文件,那接下来我们再创建一个文件,那这个数据源在考不考。那兔。Five啊,也就是说打印到控制台。那进来之后,我仍然把这个配置信息粘过来之后呢,给大家解释一下。行,放到这儿之后给大家解释一下,接下来我们来看一下这个配置文件啊,首先呢,我们把它定过来。按照它进行配置,比如说卡m channel以及log s好。那仍然是配置的这个五步骤啊,第一步呢,定义组件,第二步配置S,第三步配置channel,第四步配置S,第五步呢,拼接对应的主件就行了。那好,那这里面呢,我们定义的A阵的名称仍然是A1。那我们下面对应的这个S呢,哎,就一个re sing一个啊China一个C定义好,那定义好之后首先配的就是这个S,那S是卡卡S,卡瓦S怎么配啊。
02:09
直接来到这里面。来到这之后找到的就是卡瓦S,那卡瓦S斯呢,一共有这么多配置信息,还是仍然找加粗的内容对吧?啊,加粗内容加内容这些这些啊。那这里面有两个注意的地方啊,它。他呢说啥呀啊,说这个属性配置呢,啊,这个优先级啊,要高于这个卡瓦托啊啥意思呢?比如说它可以配置监控符合正则表达式的主题。那上一个呢,只能一个一个的指定的去配置哪一个主体,那这里面二选一。其他的没啥说的,那你直接看他对应的案例就行了,把它案例定出来。好,拿过来,拿过来之后我们对比一下。首先第一个是要配置它对应的类型,那类型呢,你看跟这个类型是一模一样的啊,从他官网上拿过来就行了,那接下来我们这里面配置的是这个BA size啊,那这个be size呢,其实不是必须配置项啊,也就说你一批次拉取多少条日志啊,那这里呢,默认是50条啊。
03:15
那还有呢,是每批次与每批次拉取的一个间隔时间啊,那这是200MILLIONS啊这个值,那好,那接下来你要连接上对应的卡法集群,那不serve,其实这个呢,应该补齐,还有1029092,还有1039092 1031049092对吧?啊,最少补两个啊。那下面我要消费的这个主题是对应的是first主题,诶你看first主题。诶,它的配置是两个,那再往下你得定义一个消费者主,哎消费者主的ID呢,这呢是必须得给一个,那当然了,这个是根据我们用户自己来配置,想怎么配怎么配,那这里面它默认给的是啊自定义嗯主ID。也一样啊,无所谓,那行,那这个呢,就是配置对应的这个叫卡夫卡source,那下面呢,我们来配置一下memory channel memory channel上节课是不是配置过了啊,那这里面我就看一眼就行了,你看对应的就是memory channel啊,这两个参数呢,可配可不配,默认值呢都是100。
04:11
那下面还有一个就是这个log s他。他呢,我们看一眼啊,Log根。复制过来,CTRLF粘贴好。那对应的这个就是log性格,其实啊,它只有三个参数啊,那两个参数呢,是必配项,一个是传,一个是type类型啊,那你直接按这个配就行了,那这这里面就把它配上对吧?啊后面那个是拼接组件,我们都可以把它拼接上啊,相当有指定这个数据类型的就是logo啊,这样就简单了啊,非常简单粗暴。那那这个完事之后呢,下面呢,我们就开始启动对应的这个啊,启动它啊嗯,那这个我就不敲了啊,大家看一眼吧,跟上节课的差不多。战略课呢,仍然是用这个弗NG啊,Agent固定写法杠C,哎,指定这个com配置文件,杠N呢是指定这个agent的名称,那么是A1啊,然后杠F是刚才写的这个配置文件好不好,To file那后面加上了一个它原因是因为你这里有一个log s。
05:08
Log呢,有一个打印日志的级别,那有这个error啊,In control啊,类似这些级别啊,那这里面我们就按照正常的打印普通信息啊就可以了哈,那把它启动。好,那现在呢,是在前台启动,如果你加一个女号的话,就是转到后台进行一个运行啊。啊,那他启动完毕之后呢,下面我们应该干什么事呢?看一下这张图。看一下这张图,哎,我们的这个flu呢,已经服务启动了,打印到控制台这边也已经准备好了,那么这个卡把的这个first的主题也已经创建完毕了,那下面就是生产者往这里面发送数据,然后观察空台有没有数据,这不就完事了,哎,这样一个过程啊,那今天呢,我们就创建一个卡不卡的生产者。
06:00
那我们来到对应的叫104层。104有了103吧。变卡卡。Control臭producer,尴尬。是。HIOP1029092好。呃,连接上之后呢,杠杠topic。走。那下面呢,我们就往里面发送数据。哈,走。发送一条,那你观察一下啊,这边的消费道数据,看他这边有没有数据啊。看哎,这边呢,是不是也接收到了一条日志啊,你看这个日志信息,我打的是一个哈喽,你看是不是哈喽,哎,我再来一条,来一个艾特硅谷。然后仍然观察这边是吧,又来一条日志啊,哎,这个呢,就是整个这个通道呢,就打通了,也就是说弗禄作为卡瓦的消费者,那这个案例呢,我们也完成了哈。
我来说两句