如果kafka broker宕机，生产者抛出异常的时间会更长

Question

我想处理的情况下，如果卡夫卡经纪人在卡夫卡生产者端，那么它需要更长的时间来显示以下错误。

无法发送；嵌套异常是org.apache.kafka.common.errors.TimeoutException:使1条记录过期- 30030 :自批量创建以来已过0.5毫秒，外加延迟时间

如何处理这个问题？

Answer 1

生产者等待request.timeout.ms，等待来自代理的响应。

配置控制客户端等待请求响应的最长时间。如果在超时之前没有收到响应，客户端将在必要时重新发送请求，或者在重试次数耗尽时使请求失败。这应该大于replica.lag.time.max.ms (代理配置)，以减少由于不必要的生产者重试而导致的消息重复的可能性。

默认设置为30000ms。如果您试图减少它，请小心，如果太短，可能会导致生产者重试太快并产生重复项。