00:00
呃,那接下来呢,我们把它启动,但是现在不要着急启动构建这个对象要卡卡对吧,所以呢,我把这个卡夫卡去开一下啊,在集群当中我开一下卡夫卡ZK我已经开过了。哎,我关掉了对吧,刚才关掉了啊。然后把卡夫卡打开,然后还得开一个消费者吧。CP到o Mo到卡夫卡当中,我把卡夫卡集群开一下。好,那我们就开一下这个消费者B,叫卡夫卡的一个consumer。刚刚不抓的杠。对吧,然后哈杜102冒号,给一点时间想一下端口号不用敲了啊,我可能等不到你们敲,我就自己写了,自己想一下卡不卡的端口号是多少。哎,是9092对吧,然后呢,指定我们的消费的主题,我们主题呢叫ods。
01:00
Bases。Log这个主题。嗯。没问题吧,好,那有一个问题啊,这110086。拖出去枪毙吧。啊,现在你们在在家里上课就可以皮了是不是?啊,我揍不着你,踹不着你是不是?然后就可以随便提了,1081010都来了,是不是有点过分了?行,那这个地方呢,我们消费这个主题啊,消费这个主题啊,那有一个问题啊,你们基金当中这个主题肯定没有吧,对吧,我是创建了啊,如果没有的话,你启动它会报一个警告。啊,他会报一个警告,他会他会告诉你这个主题不存在啊,那有一个问题啊,就这边生产者往这个不存在主题发能不能发呀。假如说主题我没有创建。
02:01
能不能发出去。可以吧,因为在默认的配置当中,我们只要没有改过,他默认生产者是可以自动创建的啊,可以自动创建的啊,所以呢,你做试的时候也无所谓,就这样就行了,但是你直接消费的时候,他会报一个警告,这个我说过了啊,说过了好,那接下来呢,启动我们的服务端。启动服务单,等会儿如果说我们能看到这个数据能够在消费者被消费者消费到就可以了,好,你看啊这个日志,注意只打印到这儿。跟刚才日志不一样了,跟刚才日志不太不一样了,这是里边C走出来的,它并不是日志啊,它是Co。就是打印出来的啊,并不是日志,为什么呢?因为我们这个时候刚才在log back当中配置了,我只打印当前这个类里边的日志,我只打印这个类里边日志,所以其他的不属于该类的日志统统都不打印啊,所以它的启动之后就长这个样子就对了啊,那没有问题,接下来最后我们是不是启动我们的架包。
03:07
对吧,我再开一个。去启动我们的架包追末Li rt好,然后Java杠加,然后追末。啊,走你。好看一下这边的,诶地址我看一下啊,这个地方。他说我们这个地址还是有问题是吧,嗯,我看一下我是不是刚才改了呀。我不会IP地址又变了吧,不应该啊,我这会儿怎么可能IP地址会变呢,我我看一下啊,检查一下。I看14.2没问题,然后服务端。
04:02
J logo。啊对对,8081 8081没问题啊,我也我也反应过来这个问题了,因为之前我们是8080嘛,这个是8081啊,所以地址错了,他报错对吧?Application,然后呢,这个地方我们改成8081就好了,对吧,所以说这个东西还是要注意一下,然后接下来我们重新启动啊,你看有三位大佬说出来了这个问题啊。呃,我觉得这个时候应该有鲜花和666了。好,那这个时候success了对吧,那看这个我们这个地方。有数据对吧,数据过来了,而且在滚动,而且滚动更重要的我们看卡夫卡,卡夫卡消费者,这是不是数据也通了,注意这是我们的消费者,对吧,然后呢,数据也有了,那这个呢,我就通了,也就是说在本地测试,我们是可以将数据写到卡夫卡里边的,没有问题,完全没有问题,OK吧,是这个点。
05:03
啊,这是本地测试啊。
我来说两句