apache-kafka - 需要一些关于 kafka connect 中的错误处理的说明

Question

我正在查看以下站点KIP:298：Connect 中的错误处理

在示例 2 中，以下配置将做什么？更多信息或示例可以帮助我理解。：-

# retry for at most 10 minutes times waiting up to 30 seconds between consecutive failures
errors.retry.timeout=600000
errors.retry.delay.max.ms=30000

还有一件事是，在处理 sink 连接器时，当我因为重复记录而遇到一些错误时，它会不断尝试一段时间，如何设置我们自己的退休限制？errors.retry.timeout=0即使重复键错误连续重试某些次数， 我也尝试设置，但如果错误是由于架构或序列化程序引起的，则不会重试。

最后，errors.log.enable当这是真的时，这些日志存储在哪里？我正在检查连接日志，但无法找到默认日志与 errors.log.enable 设置为 true 时的区别。

标签： apache-kafkaapache-kafka-connect