在kafka v 0.8.2中，作为生产者而不是一次只发送一份生产记录列表是否仍然可能/有益？检查api时，似乎org.apache.kafka.clients.producer.kafkaproducer无法使用一个send调用发送多个producerrecords。
但是，在javaapi下的producer中，可以发送keyedmessages列表。有人能解释一下区别吗？或者给我指出正确的方向？非常感谢。
在kafka v 0.8.2中，作为生产者而不是一次只发送一份生产记录列表是否仍然可能/有益？检查api时，似乎org.apache.kafka.clients.producer.kafkaproducer无法使用一个send调用发送多个producerrecords。
但是，在javaapi下的producer中，可以发送keyedmessages列表。有人能解释一下区别吗？或者给我指出正确的方向？非常感谢。
2条答案
按热度按时间kkih6yb81#
javaapi下的producer是旧的实现，在客户机中被新的实现所取代。新的producer实现仍然可以将消息批处理在一起，但它将在后台执行，并且在执行发送调用时，您将获得每个消息的未来返回。
批量大小和延迟可以通过参数“batch.size”和“linger.ms”来控制。有关详细信息，请参阅文档。
6g8kf2rb2#
0.8.2不支持像prevois版本那样发送消息列表。取而代之的是send(ProducerRecord<K,V> record, Callback callback)提供了回调。但是，您可以使用旧客户机，但不推荐使用，因为新的kafka客户机声称比前一个更快更好。