我想处理的情况下，如果Kafka经纪人是在Kafka生产者端，然后它需要较长的时间来显示下面的错误。发送失败；嵌套异常为org.apache.kafka.common.errors.timeoutexception:正在过期1条日志记录-0:自批创建加上延迟时间后已过30030毫秒怎么处理？
0yg35tkg1#
制作人等待 request.timeout.ms 经纪人的回应。配置控制客户端等待请求响应的最长时间。如果在超时时间过去之前未收到响应，则客户端将在必要时重新发送请求，或者在重试次数用尽时请求失败。这应该大于replica.lag.time.max.ms（代理配置），以减少由于不必要的生产者重试而导致消息重复的可能性。默认设置为30000ms。如果你试着缩小它，要小心，因为它太短，可能会导致生产者重试太快，产生重复。
request.timeout.ms
1条答案
按热度按时间0yg35tkg1#
制作人等待
request.timeout.ms经纪人的回应。配置控制客户端等待请求响应的最长时间。如果在超时时间过去之前未收到响应，则客户端将在必要时重新发送请求，或者在重试次数用尽时请求失败。这应该大于replica.lag.time.max.ms（代理配置），以减少由于不必要的生产者重试而导致消息重复的可能性。
默认设置为30000ms。如果你试着缩小它，要小心，因为它太短，可能会导致生产者重试太快，产生重复。