00:00
好,上节课我们是spring BOO作为生产者跟这个卡集群进行一个集成,那接下来我们要做的事情呢,就是哎,这个spring boot作为消费者跟卡巴集群进行一个集成。那这个消费first的主题,诶,然后进行后续的一个打印到控制台,那这个数据呢,仍然是采用生产者把数据发送过来,然后这边进行消费这样一个测试啊,那么先写一下这部分代码,那写这部分代码呢,哎,在这里面有啊,还是分为两部分,一部分呢是配置信息在这个application purpose。那另一部分呢,是对应的代码。我们又一个卡consumer啊好来到这里面创建一个类。那在这个类里面主要用来,诶写一个卡不卡消费者,那这个消费者呢,用来接收数据,那接收数据需要一个方法,哎,比如说Y的嗯c consumer对应的topic。
01:00
接收各个topic传过来的信息。那我这里面呢,那信息的话,我以这个实际类型进行一个接收好。那它怎么跟这个卡普卡进行一个关联呢?哎,那他想关联上需要添加一个注解,那这个注解呢,就是卡普卡对应的listener。监听监听对应的这里面有一个TOPIC4好,那我们就监控一个吧,就监控到for的主题啊,这样监控到之后,我这边呢,就可以对这个消息进行后续的处理,哎,我先给他打印到控制台进行一个简单打印。叫收到。消息。然后拼接上对应的这个message,这样就可以了,那么这个类啊,要想让这个卡把listener生效,那你上面呢,给指定一下,告诉他它是一个什么类呢?哎,它是一个配置类,哎,这就可以了,就能够扫描到啊对应的这个方法啊。行,那这个写完之后,我们需要来到这个application purpose里面啊,进行配置,那首先正常情况下你需要配置第一个就是连接上对应的卡法集群,诶,那我们在写生产者的时候,这里面已经写了,那这个呢,你就不用写了啊,正常情况下如果你只写消费者的话,那仍然是连接。
02:12
好不好继续。这属于必天象啊。那行,那这个呢,不写了,不写了之后我们来一个它的反序列化对吧,K。Value的反序列化。那还需要一个配参数啊,啊哪一个呢,就是消费者主ID。都给它搞定,那行从这开始啊,那我们需要一个K的杠。反系的话。这呢是K的反序的话,嗯,那我们来到仍然是来到这里面吧,啊写一下。String d,哎,这是反序的话,按住CTRL键点进去。右键copy它对应的全列名。
03:01
拿过来之后啊,一粘贴这就OK了,那么再来一个Y6。对应的D。啊啊搞定,然后呢,把这值一粘啊,那这个K和Y6的反序列化就搞定了,那下面呢,还需要对应一个消费者主。杠ID,嗯,这就来了,那这个group ID啊,我们给他一个对应的叫爱的硅谷吧,嗯,就这。行,那这个呢,就是最基本的配置信息,我们就配完了,那下面呢,我们需要对它进行一个测试啊,把它干掉OK。好吧,来运行这个程序。那first的这个啊,运行了运行之后呢,我们这里面这是之前测试的啊,哎,我们再给它发送数据。我不发送哈罗了,我发送这个艾特硅谷走。你看这边就收到了爱特相关信息,我再来一个。嗯,再来一个哈。
04:01
是不是也OK啊,再来一个。可以吧,哎,就通过这种方式呢,啊,就写了一个卡夫卡对应的一个消费者啊,非常简单。
我来说两句