卡夫卡製片人時間戳

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的製作人。