我有一个用于处理故障恢复和可重试的用例。我必须知道Flink中的可重试选项。但是在最大限度尝试重试之后会发生什么。是否移动到DLQ?如果是,我们有DLQ实施的任何文档吗。
如果已尝试最大重试次数,则作业将失败。你需要更新你的作业,以便它能正确处理你失败的原因。例如,如果您在反序列化传入数据时遇到问题,可以将该数据发送到ApacheKafka上的死信队列主题。
有关此方面的示例,请访问https://docs.immerok.cloud/docs/cookbook/creating-dead-letter-queues-from-and-to-apache-kafka-with-apache-flink/
注:我在Immerok 工作