在Kafka中，要實現消息均勻寫入每個partition，核心是通過合理的分區分配策略讓消息在partition間均衡分布。具體機制和實踐方式如下：
一、Kafka默認的分區分配邏輯（核心機制）
Kafka生產者發送消息時，通過Partitioner接口（默認實現為DefaultPartitioner）決定消息寫入哪個partition，核心邏輯如下：
-
指定partition時
若發送消息時顯式指定了partition參數，消息會直接寫入該partition。這種情況下是否均勻完全由業務控制，若指定不當容易導致傾斜。 -
有key但未指定partition時
消息的key會通過murmur2哈希算法計算哈希值，再對partition數量取模，結果即為目標partition。- 優點：相同key的消息會寫入同一個partition，保證順序性。
- 均勻性條件：需確保
key的分布足夠隨機（如UUID、隨機字符串等），避免
