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

h5qlskok  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(457)

最新的apache kafka文档(https://kafka.apache.org/documentation)claim“当事件进入一个队列时,它们被缓冲在一个队列中,直到 queue.time 或者 batch.size 已到达。”
但是,没有 queue.time 配置项出现在 org.apache.kafka.clients.producer.ProducerConfig . Kafka最新版本中最接近的配置项似乎是 linger.ms 它不提供相同的功能。此行为的原始配置以前是 queue.buffering.max.ms ,但现在已弃用。
最新Kafka的正确配置是什么 queue.buffering.max.ms 最初提供的?

l7wslrjt

l7wslrjt1#

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

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

相关问题