在Kafka中，要实现消息均匀写入每个partition，核心是通过合理的分区分配策略让消息在partition间均衡分布。具体机制和实践方式如下：
一、Kafka默认的分区分配逻辑（核心机制）
Kafka生产者发送消息时，通过Partitioner接口（默认实现为DefaultPartitioner）决定消息写入哪个partition，核心逻辑如下：
-
指定partition时
若发送消息时显式指定了partition参数，消息会直接写入该partition。这种情况下是否均匀完全由业务控制，若指定不当容易导致倾斜。 -
有key但未指定partition时
消息的key会通过murmur2哈希算法计算哈希值，再对partition数量取模，结果即为目标partition。- 优点：相同key的消息会写入同一个partition，保证顺序性。
- 均匀性条件：需确保
key的分布足够随机（如UUID、随机字符串等），避免
