kafka-producer-api - 具有消息密钥和分区的 Kafka 生产者

Question

如果我们提供消息密钥以及分区，我很想知道消息将写入哪个分区。消息是根据分区键发布还是发布到 Apache Kafka 中的特定分区？

标签： kafka-producer-api

Answer 1

如果您partition在允许您在对象中提供分区号的构造方法之一中ProducerRecord提供编号，则默认情况下将使用分区号。

仅当未提供分区号时才使用密钥。

以下是一些建议：

1. Confluent的博客提出了这一点。
2. 学习日记的教程。

编辑- 添加了更多教程参考。