相关疑难解决方法(0)

我正在使用卡夫卡。

我有一个包含 10k jsons 的列表。

目前我发送 Jsons 如下：

for(int i=0 ;i< jsonList.size(); i++){
     ProducerRecord<K,V> record = new ProducerRecord(topic, jsonList[i]);
     producer.send(record);
}

发送每条消息。

我想将列表发送到 kafka 并使 kafka 在 json 之后将其发送 json（不是包含所有 json 字符串的一条消息），例如：

ProducerRecord<K,V> record = new ProducerRecord(topic, jsonList);
producer.send(record);

我该怎么做？

谢谢