三圖搞懂Kafka生產(chǎn)者消息發(fā)布模式

? 點擊上方“JavaEdge”，關(guān)注公眾號

1 同步發(fā)送模式源碼

2 異步發(fā)送模式源碼流程

3 總結(jié)

3.1 同步發(fā)送模式特點

• 同步的向服務(wù)器發(fā)送RPC請求進行生產(chǎn)

• 發(fā)送錯誤可以重試

• 可以向客戶端發(fā)送ack

3.2 異步發(fā)送模式特點

• 最終也是通過向服務(wù)器發(fā)送RPC請求完成的(和同步發(fā)送模式一樣)

• 異步發(fā)送模式先將一定量消息放入隊列中，待達到一-定數(shù)量后再一起發(fā)送

• 異步發(fā)送模式不支持發(fā)送ack,但是Client可以調(diào)用回調(diào)函數(shù)獲取發(fā)送結(jié)果

所以，性能比較高的場景使用異步發(fā)送，準確性要求高的場景使用同步發(fā)送。

目前交流群已有?800+人，旨在促進技術(shù)交流，可關(guān)注公眾號添加筆者微信邀請進群

喜歡文章，點個“在看、點贊、分享”素質(zhì)三連支持一下~