卡夫卡生产者时间戳

Question

我无法理解ProducerRecord。

以前我是这样构建ProducerRecord的：

new ProducerRecord<String, String>("my-topic", "key", "value")

我想另外传递一个时间戳，所以我决定检查文档并发现构造函数确实允许传递时间戳。但它也需要像这样指定一个分区：

new ProducerRecord(String topic,
              Integer partition,
              Long timestamp,
              K key,
              V value)

我对传递什么作为分区参数感到困惑，因为我之前使用的构造函数正在为我处理它。

Answer 1

你仍然可以毫无问题地使用这个构造函数。您将在此构造函数中传递分区 null 并且 DefaultPartitioner 仍将负责分区器分配。只需命名确保您使用的是新的 KafkaProducer API。时间戳不适用于旧的基于 scala 的生产者。