當(dāng)消費(fèi)者嘗試連接到停機(jī)代理時(shí)，Sarama 庫中會(huì)發(fā)生什么？它會(huì)返回錯(cuò)誤嗎？
1 回答
隔江千里
TA貢獻(xiàn)1906條經(jīng)驗(yàn) 獲得超10個(gè)贊
如果這些主題的復(fù)制因子大于 1，并且這些主題分區(qū)的領(lǐng)導(dǎo)者選舉新代理，那么消費(fèi)者將重新平衡到領(lǐng)導(dǎo)者分區(qū)。
在 Kafka 的 2.4 版本中，客戶端也將能夠從同步副本中讀取，而不僅僅是領(lǐng)導(dǎo)代理，但是需要在 Sarama 的協(xié)議中添加該功能。
如果一個(gè)分區(qū)只有一個(gè)代理可用，并且它已關(guān)閉，那么 Sarama 和所有其他讀取和寫入主題的客戶端都會(huì)拋出錯(cuò)誤，是的。
- 1 回答
- 0 關(guān)注
- 101 瀏覽
添加回答
舉報(bào)
0/150
提交
取消