卡夫卡批量生產商API

我在使用卡夫卡作爲消息傳遞平臺。我需要發送一大堆消息給它。我正在尋找一個可以獲取記錄列表的批量api，但無法在kafka-clients工件中找到它。卡夫卡批量生產商API

在Java中是否有Kafka的批量生產者api？

2015-10-06 feroze

你是決定什麼意味着記錄的人，所以把數據拆分成消息必須在你身邊完成。卡夫卡製作人支持將幾個消息分批發送到更少的發送。

對於更像是散裝裝載機的東西，最近有一些與Copycat framework一致的東西。其中一些是trunk，但目前正在進行中。

2015-10-06 18:05:57 Lundahl

感謝您的回覆。但是，我不明白這是什麼意思。卡夫卡製片人api採用ProducerRecord 類型。這意味着我不能將多個記錄分批到k，v對中，因爲每個鍵都不同。對？或者也許我錯過了一些東西。 – feroze

您可以設置生產者屬性'batch.size'和'linger.ms'來控制消息如何組合在一起。 'batch.size'在發送之前控制一批消息的最大大小，'linger.ms'是一種延遲發送和等待更多消息在批量發送之前累積的方式。這全是 – Lundahl

這一切都是在後臺透明地完成的，您仍然需要在代碼中單獨調用每個記錄上的「發送」。 – Lundahl

回答