最新的 Kafka 中最初提供的“queue.buffering.max.ms”的正确配置是什么？

Question

最新的 apache Kafka 文档 ( https://kafka.apache.org/documentation ) 声称“当事件进入队列时，它们会在队列中缓冲，直到达到queue.time或”。batch.size

但是， 中不存在queue.time配置项org.apache.kafka.clients.producer.ProducerConfig。最新版本的 Kafka 中最接近的配置项似乎linger.ms不提供相同的功能。此行为的原始配置以前是queue.buffering.max.ms，但现在已弃用。

对于原来提供的内容，最新的Kafka中正确的配置项是什么queue.buffering.max.ms？

Answer 1

这个选项仍然存在于librdkafka库中，因此可以通过 config.Set (key, value) 设置。

var config = new ProducerConfig {
  BootstrapServers = "localhost:9092",
  ...
}
config.Set("queue.buffering.max.ms", "5");