我正在尝试从生产者端了解请求超时机制。假设我有以下配置集
Producer Configurations:
delivery.timeout.ms = 15000
request.timeout.ms = 10000
linger.ms = 0
reconnect.backoff.ms = 50
Broker configurations:
request.timeout.ms = 30000
现在,如果我在时间t1
发送消息并且群集已关闭,则生产方在抛出连接异常之前要等待多长时间?
request.timeout.ms
作为生产者配置定义了生产者等待请求响应的最长时间。
另一方面,request.timeout.ms
作为经纪人配置控制领导者经纪人等待acks=all
时消息的同步副本发送确认(复制消息并发送响应)的时间。 >
因此,在您的情况下,生产者将在引发异常之前等待10秒。
我运行了一个测试,发现send()正在等待以下异常