温馨提示:文本由机器自动转译,部分词句存在误差,以视频为准
00:00
三零消费者主题订阅相关操作已经看完了,那接下来呢,我们就来看一下真正的去拉取数据。那拉起数据呢,是用这个肯修模调用这个点铺这个方法啊,进行拉取,拉取完之后,那后续呢,这个是对数据进行相关操作啊,那我们进去。进去之后,哎,我们要点击它,点击它之前看一下这个值。这个值呢叫include mrter date in time啊这个值呢,默认是处对吧,来出记住,那我们进来,进来之后走到这里面,那在这里面我们干了哪几件事呢?首先我们要干的事儿就是要进行一个初始化,那这块呢,我给大家把这个原理图啊,给它定出来啊。比如说消费者原理。出来。第一章。第二章。那也说在我们之前初始化的时候,大家是不是记得,诶,我们是不是还没有看到这个消费者跟这个coordinator进行相互的一个交互信息啊,啊,那其实那马上就要看到了啊,那这块看什么呢?看这一块说刚才传进来这个值是不是一个处啊,如果说它为处的话,是不是走这个方法。
01:11
叫update assignment meter if needed啊是这么一个参数,那这块是干嘛的呢?注释一下。那这块是干什么的呢?哎,是消费者或者消费者主的一个初始化。那这呢是第一件事儿,那第一件事儿处理完之后,那接下来他干什么事儿呢?来看一下,比如说他初始化完毕之后,那接下来他就要创建一个客户端对象,这个对象也有了,那他要跟这个服务端进行一个通讯,哎,来抓取对应的数据是吧?抓取完数据放到一个缓存队列,然后呢,通过这个队列里面啊,最多一次可以取500条数据,然后进行一个反序列化和拦截器相关操作,是不是这样哎。
02:00
那接下来要抓取数据是哪一个操作呢?是这块。这块叫抓取数据,那抓取数据调用的是这个方法,那再往下看,抓回来的数据如果说不等于空,那这波数据交给谁呢?看到了吗?哎,交给对应的这个拦截器处理。诶拦截器开始处理数据,那整个这个核心步骤就完事了啊,比如说我们首先呢是诶对这个coordinator跟消费者组相关的一个初始化,然后下边就是这块。开始通过这个客户端跟服务端进行一个拉取数据,拉取数据放到这儿,诶每次呢,处理最多500条,之后呢,后续这个步骤呢,就是哎拦截器相关操作啊行,那我们先从整体上了解一下整个消费者组啊干的这么几件事儿啊。
我来说两句