1.ProducerRecord
如果 key 不為 null，那么默認(rèn)的分區(qū)器會(huì)對(duì) key 進(jìn)?哈希(采? MurmurHash2 算法，具備 ?運(yùn)算性能及低碰撞率)，最終根據(jù)得到的哈希值來計(jì)算分區(qū)號(hào)，擁有相同 key 的消息會(huì)被寫?同?個(gè)分區(qū)。如果 key 為 null，那么消息將會(huì)以輪詢的?式發(fā)往主題內(nèi)的各個(gè)可?分區(qū)。
注意：如果 key 不為 null，那么計(jì)算得到的分區(qū)號(hào)會(huì)是所有分區(qū)中的任意?個(gè);如果 key 為 null 并且有可?分區(qū)時(shí)，那么計(jì)算得到的分區(qū)號(hào)僅為可?分區(qū)中的任意?個(gè)，注意兩者之間的差 別。
2.消息發(fā)送到broker
有可能需要經(jīng)過攔截器(Interceptor)、序列化器(Serializer)和分區(qū)器(Partitioner)的?系列作?之后才能被真正地發(fā)往 broker。
生產(chǎn)者攔截器，實(shí)現(xiàn)ProducerInterceptor接口：
onSend() ：在消息發(fā)送之前執(zhí)行
onAcknowledgement()：在消息被應(yīng)答之前或消息發(fā)送失敗，優(yōu)于callback執(zhí)行。
攔截鏈：按配置先后執(zhí)行
更多關(guān)于大數(shù)據(jù)培訓(xùn)的問題，歡迎咨詢千鋒教育在線名師。千鋒教育擁有多年IT培訓(xùn)服務(wù)經(jīng)驗(yàn)，采用全程面授高品質(zhì)、高體驗(yàn)培養(yǎng)模式，擁有國內(nèi)一體化教學(xué)管理及學(xué)員服務(wù)，助力更多學(xué)員實(shí)現(xiàn)高薪夢(mèng)想。
京公網(wǎng)安備 11010802030320號(hào)