|
1,、 針對(duì)消息丟失：同步模式下,，確認(rèn)機(jī)制設(shè)置為-1，即讓消息寫入Leader和Follower之后再確認(rèn)消息發(fā)送成功,；異步模式下,，為防止緩沖區(qū)滿，可以在配置文件設(shè)置不限制阻塞超時(shí)時(shí)間,，當(dāng)緩沖區(qū)滿時(shí)讓生產(chǎn)者一直處于阻塞狀態(tài),； 2,、針對(duì)消息重復(fù)：將消息的唯一標(biāo)識(shí)保存到外部介質(zhì)中，每次消費(fèi)時(shí)判斷是否處理過(guò)即可,。 ======================================================= SpringBoot整合kafka(實(shí)現(xiàn)producer和consumer) https://www.cnblogs.com/linjiqin/p/11950758.html https://blog.csdn.net/weixin_34236497/article/details/91530220 異步配置 |
|
|
來(lái)自： syl技術(shù)資料 > 《zookeper-kafka》
