apache-kafka - 卡夫卡 : How to achieve Round Robin Partition in Kafka

Question

我是卡夫卡的新手。我的要求是，我有两个分区，例如 Partition-0 和 Partition-1，并且我有值列表，其中也包含 KEY 值。我想根据我的 key 存储数据，例如 key-1 将转到 Partition-0，key-2 将转到 Partition-1。使用旧的 API 有办法实现，就像我们需要实现 Partition 接口(interface)一样，但是我如何使用新的 API 来做到这一点。谢谢

Answer 1

如果您想要循环行为，只需在写入 Producer 时不传递 key ，DefaultPartitioner 就会为您完成这项工作。您不需要编写自定义实现。来自 javadocs:

/**
 * The default partitioning strategy:
 * <ul>
 * <li>If a partition is specified in the record, use it
 * <li>If no partition is specified but a key is present choose a partition based on a hash of the key
 * <li>If no partition or key is present choose a partition in a round-robin fashion
 */