00:00
好,接下来呢,我们来看一下卡法的自动off普赛的提交,就说自动帮我们来维护奥赛的一个提交过程,好,双击打开。看一下也就说啊,卡板呢,自动帮我们提交了奥赛的功能,那他为什么会这么做呢?哎,其实啊,他希望我们用户能够专注于自己业务的一个实现,你说你就别管其他这些小事儿了,哎,这个事儿我来,哎这个意思。那好,那要想实现这个功能,有哪些参数可以进行一个控制呢?第一个参数就是它。它呢,就是是否开启自动奥赛提交功能,那当然了,它的默认值是处,比如说选择自动帮你来完成这个事儿,那有同学该思考了,说说海哥,那我自动提交,他多长时间帮我提交一次呢?哎,其实啊,这个自动奥赛提交的时间间隔是五秒钟,比如说五秒钟我提交一次。那同学说海哥这五秒钟呢,对宋宋老师来说啊,这个时间有点长,我能不能减少一点,哎,我来个三秒啊或者一秒行不行呢?哎,当然可以了,你直接改变对应的这个参数值就可以。
01:04
那下面呢,我们来详细的看一下自动奥赛提交它底层的一个原理哈,好,那首先呢,是生产者向对应的分区里面发送数据。他发完数据之后,那这个消费者啊,就主动的去拉取数据,而且不间断的拉。那这个off outside的活交给谁了呢?哎,Offset自动到达五秒钟的时候,帮我们去提交offset,比如说consumer自动提交。他只按时间去卡,哎不管说我消费到哪了,比如说你提交完上一波offet已经五秒了,对吧?哎提交到这的时候到这是秒,那现在呢,我不管你提没提交,你走你的,然后我继续往后去拉取后续的数据,比如说现在我已经消费到四了。那再过五秒钟的时候,哎,那这时候呢,我们再进行一个后续的提交,哎,是这样一套流程啊,就是不断的拉取数据,然后奥赛的活呢,哎,甩给这个consumer啊,到达五秒钟,它自动提交就完事了啊。
02:02
好,那这是它的流程,那下面呢,我们来详细的去配置一下,这个我希望啊,把这个自动提交的五秒钟来修改为一秒钟。那这个怎么做呢?那下面我们来写一下代码啊。来到这里面,哎,复制它。然后呢,我们改个名字叫凹凸。Upset啊。拿过来之后啊,非常简单,我们来到这边配置两个对应的参数。这个参数哎,我们设置为自动提交。其实啊,这个默认它就是自动提交啊,但是我让你熟悉一下对应的这个参数是哪一个。第二那是enable,也就是说enable auto commit啊看它那其实它的默认值呢,就是true。那是不是处这个呢,你得去验证一下哈,因为呢卡把不同的版本,它对应的参数值是不一样的啊,一定要养成良好的习惯,没事呢,多看官网把它复制过来。
03:02
到这儿。横块F,好。走。你看这里面默认的值啊,就是处,比如说自动帮你进行一个提交,好,那下面呢,我们来修改一下它的提交时间。提交时间间隔。点foot。跟F第二那哪一个参数呢?哎,是这个凹凸啊。啊,Interval Ms,也就是按照毫秒值进行一个配置。那我们进去看看是哪一个参数啊。复制过来。走,你会发现这里面它默认值呢是5000,哎,那单位呢,是对应的叫毫秒,那其实折合过来就是五秒钟,好,那我们把它改一下,我希望呢,改成一秒钟,那这也值,很显然就是1000啊,1000毫秒对应的一秒钟。那下面呢,我们改完参数之后,执行一下对应的这个消费者。
04:00
执行。现在要验证一件什么事呢?我改完参数了,消费者启动,那么我启动生产者,看这个消费者能不能接收到数据,如果能接收到,就说明这两个参数是不是就哎没有影响你的一个消费功能啊,哎,那在底层呢,它会加快它的一个提交速度啊,其实我们在肉眼上是无法看到的啊,只要不影响对应的消费功能,那这事呢就成了。那来到这这个call back啊,我们发送一下。啊,那这边发送出去看看能不能接收到走诶。见证奇迹的手套是不是能够消费到数据啊?哎,说明呢,这个功能呢,是OK的哈。
我来说两句