生产者配置的request.timeout.ms和代理配置的request.timeout.ms如何一起发挥

问题描述 投票:2回答:2

我正在尝试从生产者端了解请求超时机制。假设我有以下配置集

Producer Configurations:
delivery.timeout.ms = 15000
request.timeout.ms = 10000 
linger.ms = 0
reconnect.backoff.ms = 50

Broker configurations:
request.timeout.ms = 30000 

现在,如果我在时间t1发送消息并且群集已关闭,则生产方在抛出连接异常之前要等待多长时间?

apache-kafka kafka-producer-api
2个回答
0
投票

request.timeout.ms作为生产者配置定义了生产者等待请求响应的最长时间。

另一方面,request.timeout.ms作为经纪人配置控制领导者经纪人等待acks=all时消息的同步副本发送确认(复制消息并发送响应)的时间。 >

因此,在您的情况下,生产者将在引发异常之前等待10秒。


0
投票

我运行了一个测试,发现send()正在等待以下异常

© www.soinside.com 2019 - 2024. All rights reserved.