producer - kafka生产者是否能够在列表中发送多条消息?

标签 producer apache-kafka

在 Kafka v 0.8.2 中,作为生产者发送一系列 ProducerRecords 列表(而不是一次只发送一个)是否仍然可能/有益?检查 API 后发现 org.apache.kafka.clients. Producer.KafkaProducer 无法使用一次发送调用发送多个 ProducerRecords。

但是,在 javaapi 下的生产者中,可以发送 keyedMessage 列表。有人可以解释其中的差异或指出我正确的方向吗?非常感谢。

最佳答案

javaapi 下的生产者是旧的实现,已被客户端中的新实现取代。新的生产者实现仍然可以将消息批量处理在一起,但会在后台执行此操作,并且在调用发送时,您将获得每条消息的 future 返回。

批量大小和延迟可以通过参数“batch.size”和“linger.ms”控制。请参阅documentation了解详情。

关于producer - kafka生产者是否能够在列表中发送多条消息?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/31275065/

相关文章:

java - ActiveMQ http 连接错误

docker - 从 docker 主机外部与 kafka docker 容器交互

apache-spark - 为 kafka 主题 : No current assignment for partition topic1 分配新分区(旧分区被撤销)后,Spark Streaming 作业失败

apache-kafka - 如何在Kafka的命令行中获取主题的group.id?

c - 生产者/消费者程序出现未知错误,相信是无限循环

java - 生产者消费者死锁

c - 生产者/消费者线程无法使用 pthread 进行 DNS 查找

java - 如何针对故障点确保生产者和消费者应用程序之间的kafka事务同步?

apache-kafka - zookeeper + Kafka - 无法创建数据目录

websocket - 如何使用 Strimzi Kafka Bridge 作为流媒体服务