apache-kafka - 如何将消息发送到 Kafka 中的特定分区？

Question

我创建了一个有很多分区的主题。使用控制台生产者我想将消息发送到特定分区并通过控制台消费者查看。
在控制台制作人我试过这个，

kafka-console-producer.bat --broker-list localhost:9092 --topic sample  --property parse.key=true --property key.separator=,

发送消息，

key1,another-message

但我只是对 是否感到困惑键1 代表 分区号 .

使用控制台消费者我查看了消息，

kafka-console-consumer.bat --zookeeper localhost:2181 --topic sample

我想根据分区查看消息。这是查看控制台消费者消息的正确方法吗？任何人都可以对此提供清楚的理解吗？

Answer 1

key 不是分区号，而是 Kafka 使用 key 来指定目标分区。默认策略是根据 key 的 hash 选择分区，如果 key 为 null，则使用循环算法。

如果您需要自定义算法将消息映射到您需要实现的分区 org.apache.kafka.clients.producer.Partitioner界面。您的类(class)名称必须设置为 partitioner.class生产者的属性(property)。

更新:也可以直接在ProducerRecord中指定分区号