我想处理这个案子，如果Kafka Broker落后于Kafka Producer，那么花费更长的时间来显示以下错误 .
发送失败;嵌套异常是org.apache.kafka.common.errors.TimeoutException：对于logging-0过期1条记录：自创建批处理以及延迟时间以来已经过了30030 ms
怎么处理这个？
生产环境 者等待 request.timeout.ms 获得经纪人的回复 .
request.timeout.ms
配置控制客户端等待请求响应的最长时间 . 如果在超时之前未收到响应，则客户端将在必要时重新发送请求，或者如果重试耗尽则请求失败 . 这应该大于replica.lag.time.max.ms（代理配置），以减少由于不必要的生成器重试而导致的消息重复的可能性 .
默认设置为30000ms . 如果你尝试减少它，请小心，因为太短可能导致 生产环境 者重试太快并产生重复 .
1 回答
生产环境 者等待
request.timeout.ms获得经纪人的回复 .默认设置为30000ms . 如果你尝试减少它，请小心，因为太短可能导致 生产环境 者重试太快并产生重复 .