hadoop - 在Kafka中如果参数 "retries"设置为1或更多，那么会自动重试吗？

Question

retries 参数说明

Setting a value greater than zero will cause the client to resend any record whose send fails with a potentially transient error. Note that this retry is no different than if the client resent the record upon receiving the error.

我想确认的是kafka框架自动重试还是需要客户端额外处理。
如果它是自动完成的，并且说 retries 设置为 1。如果 record 的发送在第二次尝试时也失败了，那么 kafka 会在重试和停止重试时以不同的方式通知我适当的错误消息。

Answer 1

是的，你是对的，重试是由 Kafka 客户端自动进行的，不需要用户应用程序进行任何额外处理。客户端库不会在重试时通知您，但它会根据您的配置使用 retry.backoff.ms 参数来定义“尝试重试失败请求之前等待的时间”一个给定的主题分区”，如官方文档中所述。当所有尝试都失败时，您将在传递给 KafkaProducer send 方法的回调中收到异常(RecordMetadata 为 null 因为没有发送记录)或通过 send 返回的 Future。