apache-kafka - 在分区上随机生成消息

Question

我在发送消息时没有设置密钥。我是否保证消息会随机发送到分区？如果不是我怎么能做到这一点？我想确保我的消费者（在一个客户组中）将被均匀加载。

标签： apache-kafka

Answer 1

如果没有密钥，您的 Kafka 生产者将 - 默认情况下 - 应用RoundRobinPartitioner，它将在分区之间均匀分布消息。

如果您正在寻找一个纯粹的“随机”分区器，您可以编写一个自定义分区器来随机分配一个分区。