就我而言,我的制作人使用 librdkafka,topic.metadata.refresh.interval.ms默认为 5 分钟。在broker端connections.max.idle.ms是2小时,我们的qps相当低,但是我们希望在rtt 20ms内完成99.9%的请求,但是如果broker关闭连接,生产者将重新建立通道并发送消息,这将获得很高的性能潜伏。看来元数据刷新不起作用。
topic.metadata.refresh.interval.ms
connections.max.idle.ms
我该如何解决这个问题?
apache-kafka
apache-kafka ×1