在 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/