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

Question

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

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

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

Answer 1

这个选项仍然在库librdkafka中，所以它可以通过配置进行设置。设置(键、值(。

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