0.8.2 Kafka Producer 是否为您管理分区？

Question

我很难理解在新的 0.8.2 生产者中什么（如果有的话）相当于 0.8.0“partitioner.class”配置属性。

Answer 1

我相信他们从0.8.2 引入了org.apache.kafka.clients.producer.ProducerRecord<K,V>，它采用主题名称、可选的分区号以及可选的键和值。您通常可以像

一样使用它

    ProducerRecord<String,String> producerRecord = new ProducerRecord<String,String>(topic, key, value);

From the doc

如果指定了有效的分区号，则在发送记录时将使用该分区。如果未指定分区但存在键，则将使用键的散列选择分区。如果既不存在键也不存在分区，则将以循环方式分配分区。