减少 KafkaProducer 发送异步响应时间

Question

我的 Java KafkaProducer 能够在成功/失败的情况下正确发送消息并获得异步回调。 每当出现故障时，在回调中，我都会收到“60000 毫秒后更新元数据失败”。 即对于每个错误情况，我需要等待 6000 毫秒，即 6 秒。 如何减少回调响应时间？它是可配置的并且可以在生产者属性中设置吗？ 然后我必须使用哪个属性键将时间从 6000 毫秒减少到比这更少的时间。 我已经尝试将 max.timeout.ms 和 request.timeout.ms 设置为 3000（作为字符串或整数。但它没有反映。

Answer 1

Failed to update metadata after 60000 ms 表示客户端无法在指定时间内从代理检索元数据。如果你想减少这个超时，生产者配置max.block.ms可以设置为较低的值。