00:00
好,上节课我们把这个弗link作为生产者跟卡普卡呢已经集成完毕了,那接下来我们要做的事情就是弗link呢,作为消费者来消费卡卡的某一个主题,哎,这样一个过程,那好,那我们来看一下这个消费者代码哈,那我们先创建一个弗Li卡普卡肯休一,诶那同样道理,弗Li卡普卡consumer呢,它系统里面也有这么一个名字,那为了跟系统这个名字避开呀,哎,我们加了一个一好吧。那拿出来之后开始写一个消费者。没方法,哎,那这里面有几步呢?第一步仍然是获取环境。那第二步呢,哎,你要创建一个消费者啊。创建一个。消费者啊。那么第三步呢,第三步你就要让消费者跟你这个环境是不是得关联在一起啊,你说关联。消费者。
01:00
和对应的这个flink流。那关联完毕之后,那第四步呢,就是对应的一个执行操作。那来呗,先看一下第一步,那第一步呢,我们这里面用这个STEM。诶环境它然后点钙的环境。拿到那这个呢,Env OK,那么这个因为啊仍然得set一下这个巢数啊,这个常数,那这个巢数呢,仍然跟你这个主题对应的分区有关系,我这是消费者是吧,你三个分区,那我就设置三个巢数进行一个消费,那么这样呢,我的效率呢是最高的哈,好其实就是资源。那下面呢,我们开始创建对应的卡卡消费者来呗,又一个。Link卡不卡?很猛,哎,别导错了啊,这个那是它,那它这里面第一个参数,第一个参数呢,是消费的主题。First。
02:01
那下一个,哎,下一个呢,仍然是反序的话,那反序的话呢,我们就拗一个。Simple,哎,这里面有个模板代码啊,直接拿过来就可以了,就省去了你在这个属性文件当中,哎,需要配置对应的K和Y6的反序列化啊。那这里面需要一个purpose,那purpose得需要new一个啊。拿过来,假帽。成拿到它之后,第一时间给它放进去。哎,这儿呢,点帽返回,返回对应的这个是什么呢?哎,这个呢,就是对应的叫卡法肯。哎,添加完毕了,那添加完毕之后仍然是你这个消费者到底消费的是哪一个卡法集群呢?那你是不是得配置一下啊,哎,Power点或那对应的就是consumer。看这第2BOO serve必须得连接上。I度吧,1029092。
03:01
Hi 1039092ok。这样呢,就连接上了,当连接上之后,那这个呢,反区的话也已经写完了,哎这样就OK了,那当然了,这里面这个主ID啊,我没有写,其实呢,你也可以给一个主ID啊,他这个不写主ID呢,是不报错的啊注意。那这个呢,就是consumer.group ID给他一个呗。给他一个太子呢?哎,这样就OK了,那这个消费者准备完毕之后,那下面呢,就让这个流跟这个消费者进行一个关联,怎么关联呢?因为点S。哎,其实数据的输入源是这。翻过来。添加进去,哎,然后呢,我希望消费的数据呢,进行一个打印,那我就print打印到控制台,那后面这块呢,进行一个执行,那就是因为点执行。把这一堂抛出去。这样就OK了,那下面呢,我们来演示一下,看行不行啊,执行一下代码走。
04:03
他这边启动,那下面我启动一个生产者,那刚才是不是写了一个生产者呀,就他。行。监控一下消费者,看能不能消费到数据啊。这里面大家可以看一下,哎,其实呢,它消费了很多数据,比如说at硅五,你看这么多数据,其实啊,它是从头开始进行一个消费的啊,类似于杠杠from beginning啊这种方式,你看以看这里很多对吧,来再往后看。那最后这个位置消费的应该是Hollywood。来找啊,这里数据特别多,他把历史的数据都消费出来了,那我们再来发一下啊,看是不是。再来发送。你看哎对应的hello at硅谷,那它这种方式呢,是从杠杠from beginning啊开始进行一个消费的啊,这个呢要注意一下,那当然这个是不是可以配置啊,哎,你可以改变它这个卡卡默认从哪开始消费,比如说你可以是刚刚form不的这种,也可以是latest,是不是一个对应的参数啊,你可以在这里面进行一个配置。
我来说两句