還有l(wèi)eader中遠(yuǎn)程副本,HW不會(huì)更新,如果沒更新豈不是一直都是0?那么這個(gè)數(shù)據(jù)是什么作用呢?
Kafka - 關(guān)于高水位和Leader Epoch高水位的作用 在 Kafka 中,高水位的作用主要有 2 個(gè)。 定義消息可見性,即用來標(biāo)識(shí)分區(qū)下的哪些消息是可以被消費(fèi)者消費(fèi)的。 幫助 Kafka 完成副本同步。 下面這張圖...
還有l(wèi)eader中遠(yuǎn)程副本,HW不會(huì)更新,如果沒更新豈不是一直都是0?那么這個(gè)數(shù)據(jù)是什么作用呢?
Kafka - 關(guān)于高水位和Leader Epoch高水位的作用 在 Kafka 中,高水位的作用主要有 2 個(gè)。 定義消息可見性,即用來標(biāo)識(shí)分區(qū)下的哪些消息是可以被消費(fèi)者消費(fèi)的。 幫助 Kafka 完成副本同步。 下面這張圖...
有幾個(gè)問題想問下博主:
1.epoch這邊leader是有持久化,放在一個(gè)文件上的,那么follower上有持久化嗎?我看博主上面說的是緩存,broker宕機(jī)了就沒了吧
2.min.insync.replicas=1,一旦leader寫成功就認(rèn)為已提交,那么follower在fetch最新消息的時(shí)候,還沒拉取到,這個(gè)時(shí)候leader掛了,follower成為了新leader,這個(gè)時(shí)候新leader沒有這個(gè)“已提交”數(shù)據(jù),不就丟失了嗎?這個(gè)和hw、epoch機(jī)制都沒啥關(guān)系吧
Kafka - 關(guān)于高水位和Leader Epoch高水位的作用 在 Kafka 中,高水位的作用主要有 2 個(gè)。 定義消息可見性,即用來標(biāo)識(shí)分區(qū)下的哪些消息是可以被消費(fèi)者消費(fèi)的。 幫助 Kafka 完成副本同步。 下面這張圖...