消息键与分区策略
学习 Kafka 如何使用消息键将记录路由到分区、这种机制如何保证顺序，以及如何设计消息键和自定义分区器。
消息键与分区策略 是 CoddyKit 上的免费 Apache Kafka & Stream Processing Fundamentals 课时。 这是第 4 节课，共 4 节。 你可以在下方免费阅读本课时的完整内容 — 然后在浏览器中使用内置代码编辑器和全天候 AI 导师进行实践。 这是 Apache Kafka & Stream Processing Fundamentals 学习路径的一部分，你的进度在网页和 CoddyKit 应用中同步。 Apache Kafka & Stream Processing Fundamentals 课程共包含 4 节课。
本课时的部分内容尚未翻译，以英文显示。
The Role of the Key
Every Kafka record can carry an optional key. The key is not just data — it determines which partition the record is written to.
Default Partitioner
When a key is present, the default partitioner hashes it and maps the hash to a partition. The same key always lands in the same partition (for a fixed partition count).
partition = hash(key) % numPartitionsNo Key Behavior
If you send records without a key, the producer distributes them across partitions (sticky batching in modern clients) for balanced load — but ordering across partitions is not guaranteed.
Ordering Guarantee
Kafka guarantees ordering only within a partition. By keying related records (e.g. all events for one order id), you guarantee they are processed in order.
send("orders", orderId, event); // all events for an order stay orderedChoosing a Good Key
A good key reflects your ordering and grouping needs.
- User events keyed by userId.
- Order events keyed by orderId.
- Avoid keys with too few distinct values (causes hot partitions).
Hot Partitions
If one key value dominates traffic, its partition becomes a hotspot while others sit idle. Watch key cardinality and distribution to keep load balanced.
Keying in Spring Boot
Pass the key as the second argument to send; Spring forwards it to the partitioner.
kafkaTemplate.send("orders", order.getId(), payload);Custom Partitioner
For special routing logic, implement the Partitioner interface and override partition().
public int partition(String topic, Object key, byte[] keyBytes,
Object value, byte[] valueBytes, Cluster cluster) {
return isVip(key) ? 0 : 1 + (Math.abs(key.hashCode()) % (n - 1));
}Registering the Partitioner
Tell the producer to use your class via configuration.
spring:
kafka:
producer:
properties:
partitioner.class: com.example.VipPartitionerPartition Count and Keys
Changing the partition count changes hash % numPartitions, so existing keys may move to new partitions, breaking ordering. Choose partition count carefully up front.
Putting It Together
Keys are the link between data and partitions. They give you per-key ordering, drive load distribution, and can be customized with a partitioner for advanced routing.
Quick Check
Test your understanding of keys and partitioning.
Recap
You learned message keys and partitioning.
- The key determines the target partition via hashing.
- Same key, same partition, ordered processing.
- Low-cardinality keys cause hot partitions.
- A custom Partitioner enables advanced routing.
常见问题解答
「消息键与分区策略」课时是免费的吗？
是的 — 「消息键与分区策略」的完整文本可在网页上免费阅读。要进行交互式练习（内置代码编辑器和全天候 AI 导师）并解锁 Apache Kafka & Stream Processing Fundamentals 课程的其余内容，请升级到 CoddyKit PRO。 Apache Kafka & Stream Processing Fundamentals 课程共包含 4 节课。
「消息键与分区策略」这节课中我会学到什么？
学习 Kafka 如何使用消息键将记录路由到分区、这种机制如何保证顺序，以及如何设计消息键和自定义分区器。 你通过在浏览器中直接运行的动手代码来练习 Apache Kafka & Stream Processing Fundamentals，全天候 AI 导师会在你学习这节课的过程中回答你的问题。
学习 Apache Kafka & Stream Processing Fundamentals 需要有经验吗？
无需任何先前经验。CoddyKit 上的 Apache Kafka & Stream Processing Fundamentals 课程适合初学者到高级学习者，你可以从这里开始或从头开始，按照自己的节奏学习。 这是第 4 节课，共 4 节。
「消息键与分区策略」课时需要多长时间？
大多数 CoddyKit 课程大约需要 5–10 分钟。每节课都很精短且互动，所以你能稳步进步，并在网页和应用中从离开的地方继续。
我能在这节 Apache Kafka & Stream Processing Fundamentals 课中编写并运行代码吗？
能。每节 Apache Kafka & Stream Processing Fundamentals 课都包含内置代码编辑器，你可以在浏览器中直接编写并运行真实代码，并获得即时 AI 反馈 — 无需本地设置。
此课程中的所有课时
- 向 Kafka 生产消息
- 从 Kafka 消费消息
- 理解分区和偏移量
- 消息键与分区策略