apache-kafka - 对于最初提供的 `queue.buffering.max.ms`，最新的 Kafka 中的正确配置是什么？

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");