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

h5qlskok 于 2021-06-07 发布在 Kafka

关注(0)|答案(1)|浏览(456)

最新的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 最初提供的？

apache-kafka kafka-producer-api

来源：https://stackoverflow.com/questions/43376485/what-is-the-proper-config-in-the-latest-kafka-for-what-queue-buffering-max-ms

1条答案

按热度按时间

l7wslrjt1#

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

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

赞(0）回复(0）举报 2021-06-07

我来回答

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

1条答案

相关问题

热门标签

最新问答