Kafka系列2:深入理解Kafka生产者(12)

分区

分区器

上面在说明生产者发送消息方式的时候有如下一行代码:

ProducerRecord<String String> record = new ProducerRecord<>(\"Topic\" \"k\" \"v\");

这里指定了Kafka消息的目标主题、键和值 。 ProducerRecord对象包含了主题、键和值 。 键的作用是:

  • 作为消息的附加信息;

  • 用来决定消息被写到主题的哪个分区 , 拥有相同键的消息将被写到同一个分区 。

键可以设置为默认的null , 是不是null的区别在于: