默認情況下，kafka采用的是hash取模的分區(qū)算法。如果Key為null，則會隨機分配一個分區(qū)。這個隨機是在這個參數(shù)”metadata.max.age.ms”的時間范圍內(nèi)隨機選擇一個。對于這個時間段內(nèi)，如果key為null，則只會發(fā)送到唯一的分區(qū)。這個值值哦默認情況下是10分鐘更新一次。

關(guān)于Metadata，這個之前沒講過，簡單理解就是Topic/Partition和broker的映射關(guān)系，每一個topic的每一個partition，需要知道對應(yīng)的broker列表是什么，leader是誰、follower是誰。這些信息都是存儲在Metadata這個類里面

?

總結(jié)

以上是生活随笔為你收集整理的消息默认的分发机制的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。