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

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

?

總結

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

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。