00:01
啊,那么这块呢,其实是吧,要啊这个是比较重要的东西了,比较重要的东西对吧,这个重要的并不是说哎,我们在操作的时候,需要我们干什么干什么,如果是从操作角度来讲,咱们需要做的事呢,很少,但是呢,这个原理性的东西,这块大家呢,一定要知道,对吧?那就是什么呢?那就是数据可靠性它的一个保证。啊,什么意思啊,同学们,刚才呢,咱们给大家介绍了卡夫卡的工作流程,呃,工作流程什么样的呢?这是我们生产者发送消息,然后接下来对吧?那么咱们现在呢,会把我们这个leader消息同步到我们这包号上去,那我问大家这个卡不卡,他怎么知道我现在消息发送成功了呢?就我怎么知道我现在我给往卡不卡发消息,那我现在生产者怎么知道我这个消息发送成功呢?有什么a cck对不对,对吧?所以说呢,那么咱们现在呢,在这里数据可靠性的保证,那其实呢,是不是你们告诉我ACCT就可以了,对吧,就是你最起码啊,然后我问你对吧,我就是跟你聊的时候,我现在生产者发送消息给谁给卡不卡对吧?那我现在我怎么知道,我现在生产表这个消息发送成功了,那么这时候你得告诉我有一个AC的机制,AC是什么,是不是就咱们这个应答机制啊,对吧,你给我发消息,我给你一个响应说诶我现在啊。
01:25
收到咱们这个消息了,对吧?如果收到的话,哎,那我就发通告,如果没收到的话,那么咱们是不是要重新发一下呀,对吧?所以说呢,那这个时候咱们这里AP的机制你必须得知道具体怎么做呢?当我生产者给咱们的卡卡发的消息的时候,他会给你一个响应来确定我们收到消息了,如果说啊,我现在短没有这个确认收到,那么这个时候呢,我要继续去发送咱们的消息啊,我要继续去发送的消息,对吧?好了,那么这块呢,是关于我们现在呢,它的一个AC对吧?那接下来这个继续往下面来走,啥时候去发送在ACK啊,其实我现在在咱们这里,我什么时候去把咱们AC的消息就应达给我们这生产者,给他响应回去。
02:11
什么时候给的英答啊,应该有两种方式吧,第一种方式什么?第一种方式是我们现在呢,你在咱们这里,你这个消息肯定是你发送消息,你给谁和你交互,是不是咱们leader你交互啊,对吧?那我现在第一种方式什么呢?第一种方式是不是应该等我们现在这个过半的都数据都同步了,那么这个时候给你响应,那么第二种方式是不是咱们所有的是是都同步完之后我再给响应,对吧?所以说呢,那么咱们现在何时发送SK,那目前呢,有两种形式啊,那么第一种形式呢,就是半数以上的follow同步完成,那么这个时候给我们producer来发送我们的ACK,那么另外一个呢,是全部的follow,然后完成才去发送ACK,卡夫卡用的是哪一个?
03:01
默认是哪一个,卡不卡,用的是哪一种,现在有两种方案,一个是半数,一个是全部,你们都学杂了对吧,这个没有什么默认对吧,这个就这个东西就两种方案,咱们其实现在卡不卡,其实用的就是哪个不需你们指定,其实这哪个啊。你们用的半数是吧,你们怎么设置的用的半数啊,有这么几个值,有什么有什么一对吧,然后什么有什么二,有什么零什么一什么负一是吧,然后你们设置负一是吧的半数是这个吗。那你们现在说这两种区别是什么?这个这两种方案各有自自己的一个优缺点吧,对吧,如果说我现在半数以上的这个优点是快,对吧,然后呢,如果是全部的话,案这个稍微延迟稍微高一点,然后呢,咱们这个看对比我们现在第二种方案它的一个优点在哪。
04:14
优点在哪?可靠性对吧?注意啊,同学们,假如说啊,我现在呢,在咱们这里边,我这有个集群对吧?集群呢,我现在想让我集群至少有三台机器,它可以正常运行,如果说现在啊,我想让我这个这个photo至少有三个节点正常运行,我问大家,如果第一种方案的话,它需要多少机器才能够保证至少三台机点正常运行,七台能理解吧,就如果说你要想让咱们这个服务这个机群就要求按照要求至少三台能正常运行的话,你是不是得最少我准备七台服务器,因为咱们现在是不是半数以上这个包的头发时它才可以行啊,对吧?所以说那你想一想,我要想要三台正常运行,我至少是不是应该有七台,我才能够保证咱们现在三台正常运行啊,对吧?那如果说我现在第二种方式呢,我要想要这三台正常运行,大家想想我这个里边准备多少台服务器,四台是不是就可以了呀,对吧,是不是准备四台就可以了,对吧?所以说啊同学们,那么咱们现在呢,在咱们这里对吧?那么我们现在这两。
05:20
的方案呢,其实对各有优缺点对吧,那么如果说我们这里啊,在咱们这个第一种方案的话,对吧,那么它的延迟低对吧,但是呢,对吧,它容忍我们现在N个节点故障,需要我们的二零甲一副本,就是说所占的机器啊多对吧,然后第二种方案呢,延迟高,但是呢,我们这个所用的机器少,对吧,那么卡夫卡它使用了什么呢?使用第二种方案,也就是说咱们现在在咱们这里边对吧,它使用的是我们全部对吧同步完成,对吧才发送的A对吧才发的A对吧说师,那这个延迟是不是比较高啊对吧,虽然说啊网络延迟对吧这个稍微高一点,但是对于我们这卡法来讲,它的影响呢比较小。
06:03
对吧,比较小对吧,然后呢,咱们现在呢,在咱们这里对吧,我们如果说啊,假如说同学们,我现在在咱们这里是第一种方案,对吧,我一个这个leader过来,然后呢,你会准备咱们这七台fo,七台fo对吧,那你想一想,咱们每一个fold对他做一个备份,做备份这里是不是有大量的一个数据融余标,对吧,其实没必要这么多嘛,倒没必要这么多,所以说呢,我们这个卡不卡,它使用的呢,是我们的第二种方案。你们现在用的第一种吗?第二种状啊,这个啊应该是第二种啊,同学们,然后你们看一看,我再往下讲,你们看看是不是哪一块激活的,对吧?我一会告诉你们想你们说的那个第一种知识是什么?对,因为这里说的东西啊比较多啊这块呢,到目前为止同学们能跟上,还没到难的地方,应该可以跟上,对吧?现在咱们是不是只有一个ACK的机制啊,就是什么时候给咱做咱们的应答对吧?那我们说啊,那是等所有的foer都同步完成之后,然后咱们卡夫卡才会给生产者一个响应,对吧,给他一个AC对吧?那么接下来,那么这里啊,啊有问题了对吧?有问题了什么呢?说假如说啊,同学们,我现在这里边啊,生产者发送的消息,然后给我们的leader了,然后呢,这个leader是不是要把这个数据同步给W了,对吧,那么我现在呢,这里边有很多个,比如说就三个。
07:37
啊,这三个版对吧,这两个同步的很快,但是这个呢,同步的很慢对吧,这个慢呢,就可能是因为网络原因,或者说我当前这台follow节点它的性能原因,对吧,很慢,那你说我现在这个东西它一直同步不完,对我一直从同步数据同不完,对吧?然后接下来那我leader是不就一直不能给咱们生产者去返回AC呀,难道这样一直等着吗。
08:04
不会吧,那这个时候咱们现在是不是又有个机制叫什么isr,对不对,这个isr是怎么回事了?我现在这里边有很多follow,但是并不是把所有的follow都来纳入我的统计范围之内,什么呢?我拿出一个集合来,对吧?就如果说当前这个follow啊,它比较慢,性能比较低,或者长时间没有响应,那么这个时候我呢,就不把这个photo放到我们现在这个isr里边,就我在同步的时候,我指什么,我是不是只看一看咱们isr里面follow是不是已经同步完成了,如果isr的follow同步完成了,那么这个时候我是不是再给他想就行了,就相当于什么,相当于啊,咱们在这种基的基础之上,他呢又给你来了一个小范围的东西。啊,又给你来了一个小范围的东西啊什么呢,我现在这个叫isr,这个isr本身啊,那么它的一个对吧,这个全称叫什么呢?其实就是对吧,我们的同步副本集合啊同本集合对吧?那么它的其实就是我们现在和leader保持我们的同步的一个folder对吧?那么我们现在这个有什么用呢?对吧,说我现在只要是isr的folder完成数据的同步之后,这个leader呢,就会给我们现在呢,对吧,这个什么这个product来发送我ACK,大家可以这么来理解什么呢?说现在啊,让你们投票选举对吧,不管是选什么,反正让你们班投票选举,那么第一种选举方案呢,过半数选举行了,那么第二种方案呢,咱们班全没有通过,这才可以对吧?哎,那我们现在我在选举的时候,我使用哪种,咱们班选举的时候。
09:51
全票通过才行啊,全票通过才行对吧,比如说你选择最帅的老师对不对,对吧,那你们现在第一种方式咱干什么呢?对吧,这个半数对吧,第二种方案呢,对吧,那么咱们什么对吧,这个是全部通过,咱们现在学用第二种方案,后来呀,我发现当你们填一个选举单子太费劲了,对吧,有些同学一直拖了我好几天,然后还没把这单子给我,干脆我发现咱们现在这种方案可以停,但是呢,有些同学办是拖拖拉拉,对那怎么办呢?我这样对吧,在咱们班里边,我把所有组长拉到一个群里边对吧,所以说我说你们全部都全部都都都选举,但是呢,我在这里又拖离个,把所有组长拖了,所有组长拖了,所有组长拖了,所有组长拖来了,对吧,然后这些呢,他们是没问题的,对吧,如果说啊,咱们现在的这里边某一个组长,他又长时间不给我响应,我把这组长也从我这小的这个个圈子里边给踢出去,这就是什么,是不是叫is SR呀,对吧,这个其实就是什么,其实就。
10:51
我们的isr啊,这个其实就SSR以后我在选举的时候注意咱们假如说有我们的40个人对吧,但是呢,我的isr里边可能只有多少多少个,可能只有39个,为什么我发现有一个哥们啊,这个东西长时间联系不上,打电话不接,微信不回对吧?那怎么办,我在选举的时候不能等他了呀,我把他从咱们现在这个选举这个委员会里边给他干出去。
11:15
对吧,哎,那么等他如果回来的话,对吧,那么咱再把它加进来啊,再加进来,而且咱们的isr大家还有一个作用,什么作用呢?对吧,大家想一想,我这个leader有没有可能挂,比如说选咱们班对吧,就谁呢?班长是不是有没有可能对吧,是不是,然后接下那么咱们选女的时候,大家想一那你肯定得是从积极的人里边选呀,对吧,你不能说,诶我是班长,现在真心不想干了,怎么办呢?咱们班有一个哥们联系不上了,失联了,找他干当班长都肯定不这么干,是不是得从isr里边,平时比较积极里边,对吧,这些你就选一个呀,对吧,这就是什么,这就是我们的isr,对吧,它这个作用,所以说呢,同学们咱们看一看啊,就是我们在ACP应答的时候,对吧,我们使用的是对吧,全部fold同步完成,再给我生产者来进行一个发送ACP对吧?但是呢,如果某一个folder长时间并没有向咱们leader去同步数据的话,那么说明这个folder可能有问题啊,咱们会把咱们这个folder从。
12:15
Isr里边对吧,来踢出去对吧?那么到底说多长时间之长对吧?那么有一个参数由我们现在这个参数呢,来进行设置啊,来进行设置,那么如果leader发生故障之后,他们就会从我们SR里边来选取新的leader啊,来选取新leader同学们,这个过程你没有参与吗?你们不用对吧,但是这个原理你们得会啊,这个原理你们得会对吧,就是咱们现在到AC这块对吧,那你得知道啊,这还有一个这么回事叫isr对吧,Isr然后接下来,那么咱们再往下走对吧,就是对于ACJK这块知识点还没完事呢,对吧,还没完事呢,对吧,说我现在啊。
13:00
在应答的时候,对于某些不太重要的数据,比如说我现在对就发送一些什么咱们这个普通的消息,对吧,丢失啊什么的,没关系啊,没关系,所以说呢,那我有可能我不需要等待什么呀,我不需要等待我们这个卡法给响应,咱们刚才说为什么要让卡卡说说卡卡给他保这个返返问ACK目的是什么,说保证咱们数据的可靠性了,对吧,但是我这个数据可靠性要求不高,对要求不高的话,那你想我就可以不让他给我发送AK,对吧,我只是干什么呢?生产者生产消息,只要他生产出来,发出来,到底咱们那个卡卡收没收到我不管对吧,因为我这个消息丢了,那就丢了没关系,对吧,我现在这丢一场的消息,比如说我现在去采集什么的,去采集一些我们这个评论信息,或者或者说什么登录信息,对吧,本来我一天对吧,多少条数据对吧,然后丢我一条两条的,这无所谓,你也不用给我说发啊,就是咱们现在这一个AC,对,我只要只要给你发过去了,你收据。
14:01
行对吧,说明没收到没关系对吧,那么这个呢,适用于什么呀?适用于我现在呢,对于我们这个消息可靠性要求不高的情况,对吧?那么除了这种情况呢,那么咱们现在其实还有对吧什么呢?说必须的得等到我这ACG给我发送过去,那么像这个呢,它其实也有个参数来设置,这个参数叫什么呢?叫ACKS。就是我卡卡里面有个消,这个参数叫什么呢?ACS对吧?那么这个ACPS呢,它有三个取值对吧?三个取值一个是零,那么如果零的话,那么咱们现在表示什么呀?就是表示的是我不等你了,我生产者生产消息给卡不卡对吧?我就接着该干啥干啥对吧,我不去管,我不去等你给我发走,咱们这个AK你也不需要给我发对吧?但这种情况,那一旦我消息没发送成功,也没有什么AK响应,这个数据是不是丢不了对吧?这是第一种啊,这第一种,那么第二种呢,就是我们现在生产者对吧?生产者它会等待着啊,我们现在这个卡普卡特的一个ACK响应对吧?那么什么时候呢?那么我们现在啊在等待的时候,就是说我分区的leader落盘后去返回我们这个AC,就说我现在把这个数据发送给卡夫卡了,那么卡夫卡呢,把发送卡卡的某个分区,那么这个分。
15:23
区呢,这个leader已经把这数据接收到了,那么接收到数据之后呢,那么这个时候我把这个AC返回给你啊,返回给你,那么大家想想这种情况有没有什么问题啊,对吧?比如说你看我现在在这里生产表发送一消息,然后给谁给我们现在把这个topic里边的一个分区,它的一个leader,那么如果说啊,我现在leader已经把数据给他处理完了,正常情况下leader接完数据之后,咱们的foreigner是不是对吧?要去同步数据,但是呢,还没来得及同步,对吧?咱们现在的这种策略他呢,会给我们这个生产者返回一个什么,返回一个ACK,对吧?那么生产者如果接入AK意味着什么?意味着我当年的消息是不是已经发成功了呀,你已经把这个消息是不是给我成给我给我接收到了呀,所以说你在给我响应了吗?但是这个时候来一下谁呢,Later挂了。
16:13
Leader挂了,那么如果leader挂的话,那大家想一想,我是不是要从咱们isr这两个follow中去选举一个新的leader出来啊,对吧?那大家想一想,我假如说把它当成leader了,那么这个时候咱们刚才发送过这个hello还会过来吗?没有了吗?是不是有可能会造成咱们数据的一个丢失了,对吧?这是ACG等于一的时候,它是等于什么呢?它是等我们这个啊,这个leader对吧?那么处理完数据之后,然后呢,去响应咱们这个ACP对吧?去响应C对吧?然后还有一个是等于什么呢?是等于我们这个负一,那么如果等于负一的话啊,那么咱们现在呢,它我要干什么?那么生产者要等待我们现在它的一个卡卡的AC,就是我们现在除了等于零的时候,它不返回AC等于一和等于负一的,它都要返回AC,对吧,然后呢,我们现在这个partition,它的leader和further全部落盘成功之后,才会去返回A。
17:14
CK。啊,那么这个时候会出现什么问题呢?来同学们来看啊,在这里。首先呢,我发送消息,对发送消息,然后接下来那我们把这个消息发送给谁了?发送给咱们发现leader了,Leader落盘,然后呢,这个时候他和我们一个刚才等于一的时候不一样,等于一的时候认为这个时候是不是就开始想ACCT了,但是他没有,他什么时候呢?他得先同步数据,当咱们现在把数据同步完成之后,对吧?然后接下来,那么这个时候他得干什么,他才会返回ACK,但是这个时候挂机了,他挂了,他挂了意味着什么?意味着咱们现在没给他返回ACK的嘛,没给他打回AK,那么这个生产者意味着什么呢?他感觉这个消息没发射成功啊,对吧,这个消息没发成功,那么没发成功那怎么办呢?那咱们现在在这边他挂了,你是不是在这边选取一个新的leader对吧?那么咱们现在呢,在这里我选新的leader,那我是不是得把这个消息给新的leader再发送一遍,那么这个新的消息拿的新的leader拿到消息之后是不是要落盘处理,然后接下来他是不是也要同步啊,所以说这块的消息怎么了,是不是重复了。
18:21
啊,这个消息其实是重复了对吧,所以说呢,那么大家想一想,我们现在啊,在我这里,我呢,再去保障咱们数据可靠性的时候,首先你们得知道是通过向我们这个生产者的去发送act。来保障它数据可靠性的,然后第二个,那么发送ACK的两种机制对吧?一个呢,是我们这个半数以上都要同步完成,那么另外一个呢,是我们全部follow同完成才发送,那么我当年卡卡选的谁呢?选的是全部follow同步完成来发送的,然后还有一个叫什么呢?就是我们的isr机制,那么这个SR机是解决什么问题呢?就是某一个我们的follow它长时间没有响应,那么这个时候呢,哎,我们要等我们的isr的follow他同完成之后,我呢就可以返回我们AC了,但是我们在对使用我们的一个AC机制啊再进行处理的时候,对吧?那么其实呢,我们有三种可靠性级别对吧?一个是这个ACKS的取值是零,那么这个时候呢,就相当于我们呀,不给它返回ACK了,那么一个呢,等于一对吧,一个等于负一,那么等于一的时候是什么呢?等于一是等于我们当我们现在这个leader对吧,落盘之后它就返回对吧,不等我们现在。
19:39
可以follow同步对吧?那么可能会出现什么情况呢?可能会出现数据丢失的情况,那么另外一种情况呢,是我们现在啊,等于负一的情况,如果等于负一的话,那么这个时候同学们对吧?那么有可能会出现什么情况呢?是不是数据重复的情况,怎么出现数据情复,数据重复了我现在这个leader接到数据之后,他的所有的fold都同步过来,然后接下来这个时候我呢才去返回我们的ACG,但如果这个时候leader挂了,就AC没有返回,那么我的生产者说再重复发送数据啊,对吧?那么像咱们刚才所说的这两种情况,同学们对吧?你不管是设置为我们这个负一也好,还是设置为我们现在这个一也好,对吧?那么其实呢,严格来讲它都不属于我们这精准一次性。
20:27
因为你想一想,我如果说我现在呢,在咱们这个设置的时候,他有可能丢数据,有可能多数据说这个都不属于我的精准自信啊,对吧,那么这里也有特殊的短这个叫法什么呢?如果说你把它设置为我们这个负一对吧,那么它呢,短这个之间的不会丢数据,但是会重复,这叫什么叫I的list one是不是至少一次呀,对,就是我现在啊,在到这里边它的数据至少会有一个对吧,但如果说你要把它那个级别给设置为我们这个零的话,对吧,设置为零对吧,那么这个零的话,那你想一想是不是相当于咱们这个东西对吧,这这就不给它返回ACK呀,对吧,咱们现在不返回ACK的话,那最多是不是只会发送一次呀,对吧?所以说这块呢,其实这是两个东西,一个叫at least one,一个呢叫做at most one,对吧?那么这两个呢,其实都不属于我们的精准一次性,如果精准一次性的话,对吧,就是不多不少正好一次,那么怎么样去做到咱们的精准一次呢?
21:28
注意咱们精准一次,它其实呢,呃出现在两个地方,那么我们当前呢,这个精准一次性指的是什么?指的是我们现在生产者生产数据对吧?然后接下来发给我们的卡不卡,怎么样保证咱们数据的一个精准一次性,这是第一个,然后呢,那我现在这个数据到了卡之后,我这个消费者是不是从卡卡去拿数据啊,那么这个时候怎么样保证咱们消费者消费数据的那鸡蛋精神一次性,目前我在这里注意啊,同学们,我给大家讲的到现在这块回顾的,那应该属于什么,是不是生产者生产数据到卡卡这块,它的经理自己保证了,对吧?那么怎么保证呢?对吧?怎么保证对吧?那来咱们继续往下看。
22:11
所以我们现在啊,这个要想保证它的一个精准,一次性在0.11版本之前的卡不卡这个东西保证不了。啊,你保证不了对吧,那么你只能什么呢?你只能保证数据不丢失,其实一般都是这样这种处理,就假如说你这个重复和丢失来选,你选谁。我肯定选重复,然后再下游,咱们是不是再对它进行驱重啊,对吧,你把数据先拿过来,然后到时候再驱重,对吧?但是你不能说我把这数据丢了,这丢了就真没了,对吧?但你如果说多我发点,我可以通过一些咱们手段来进行驱虫吧,对吧?哎,那我现在呢,在咱们这个0.11这里边,咱只能这样做对吧,只能这样做对吧,但是呢,这个性能对会有问题,对吧?那么从0.11版本之后,引入一个重大的特性密等性,那么这个密等性指的是什么呢?指的是我们生产者,不论像我们这个。
23:07
卡夫卡发送多少次宠物数据,那么咱们现在呢,在我们这个卡夫卡里边都只会持久化一条,对吧?那么咱们现在呢,注意啊,那么这块它是保证什么呀?它是保证生产者到咱们的卡夫卡,它的一个精准一致性怎么保证的呢?就是我刚才说这么多,咱们要想保证精经理自性怎么做,只需要一个我们的一个属性吧,就这个属性。你要想在咱们这个生产者生产数据的时候,保证清理一次性,你只需要把这个属性设置为处就可以了,对吧?但这什么呢?就是至少的一次消费,再加了一个什么幂等性本身这个词,同学们这个这个单词什么意思,幂等性嘛,就相当于把幂等性给开启了,那么幂等性的原理是什么样的呢?就说我现在把这个幂等性开启了,它怎么样去实现了咱们的经理一次性的呢?对吧?这个原理是什么对吧?那么这个原理啊,其实是这样的,如果我开启密等性之后,那么我们现在呢,这个生产者在咱们生产数据之前,它会有一个什么呢?它有一个PID,对吧,代表咱们的producer,它的一个ID,然后呢,发往咱们同一个我们分区的消息,会带一个什么呀,带一个S,其实就相当于我们的序序列号对吧,S number对吧,然后接下来那我们现在呢,在我们的卡卡这块,它会把咱们的PID,然后分区以及我们的second number做一个缓存。当你在。
24:33
在这个生产者再往这个分区再发送这个消息的时候,那么这个时他发现重复了啊,如果同样消息,那么认为我这里边已经有了对吧,它呢就对只会持久化一条啊,只有只只会持久化条,但是这种方式呢,它也有局限性,对吧?就是什么呀,就是咱们现在这PID对吧?那么如果重启还发生变化,对,同时咱们现在这个partition对吧?那么是不是我现在这个数据有可能到不同的分区里面去啊,对吧?所以说呢,密等性没有办法保证跨分区会画的一个精准一次性,那么如果保证跨分区的话,这得走不做,是不是咱们得去通过它的一个事物啊对吧,那么也是在0.11的时候,它引入了我事物,那么这个事物呢,其实去保证机准次性的话,那其实就相当于什么,把这个事物开启对吧,这个开启事物其实操作呢,和我们这个对吧,这个关于数据库其实差不多对吧,差不多对吧,也是什么,也是begin transaction对吧,然后前期那个做一个初始化。
25:33
啊,也是去提交这么事物对吧,但是注意啊,和咱们开启事务操作事物相比,那么一般呢,咱们真正在生产环境里边,那我可能怎么做,我可能就是去重啊,在咱们这个生产环境里边,我可能就什么呀,我可能就去重,也就说把AC它给设置为我们现在这个负一对吧,然后接下来那么你现在呢,这里至少一次性对吧,至少一次消费,然后接下来那我在我下游里边,比如说我们现在啊,我的下游是谁生产者生产数据,这个生产者呢,那可以理解成我们现在对吧,就是我们那个日志处理系统,他往咱们卡不卡发送数据,把咱日志呢发到卡卡里面来了,谁是下游呢?咱们是不是SPA推命啊对吧,咱对我数据呢,做一个接收,在这里我对接收的数据来做一个去除操作,对吧,一般要这样,当这种呢,其实也没问题啊吧,这种其实也没问题,对吧,这是关于什么,这是关于我们现在啊它的一个。
26:33
什么呢?关于我们对吧,这里一个精准一次性对吧,这块的事对吧?这块呢,大家要稍微注意一下啊,对吧,就是我现在对这里有一个语义对吧,一个叫什么呢?一个叫至少一次性啊,至少一次,还有一个呢,至多一次,至少一次呢,那么可能会造成数据的重复,至多一次呢,可能造成数据的丢失,对吧?那么咱们现在呢,在这里,那么它默认取值呢,应该是我们那个负一对吧?哎,默认取值呢,应该是负一对吧?诶咱们现在这里边它有个默认取值对吧?哎,其实ACPS的默认取值好了,这是关于我们现在这个,呃,基准一次性这一块,然后接下来呢,其实这里还有一个知识点,就是什么呢?其实我们卡不卡呀,这个接入到数据之后,它是不是从这个leader把咱们需把这个数据同步到follow上,那么他在同步的时候呢,其实也做了些事。
27:28
那么具体在同步的时候做哪些事是吧,咱们稍微休息一会,回来再看啊,稍微休息一下。
我来说两句