【发布时间】:2022-11-04 03:04:42
【问题描述】:
我有一个用于处理故障恢复和可重试的用例。我必须知道 Flink 中的 retryable 选项。但是在重试的最大尝试之后会发生什么。是转移到 DLQ 吗?如果是,我们是否有任何关于 DLQ 实施的文档。
【问题讨论】:
标签: apache-flink
我有一个用于处理故障恢复和可重试的用例。我必须知道 Flink 中的 retryable 选项。但是在重试的最大尝试之后会发生什么。是转移到 DLQ 吗?如果是,我们是否有任何关于 DLQ 实施的文档。
【问题讨论】:
标签: apache-flink
如果已尝试最大重试次数,您的作业将失败。您将需要更新您的作业,以便它正确处理您的失败原因。例如,如果您在反序列化传入数据时遇到问题,您可以将该数据发送到 Apache Kafka 上的死信队列主题。
这方面的一个例子可以在https://docs.immerok.cloud/docs/cookbook/creating-dead-letter-queues-from-and-to-apache-kafka-with-apache-flink/找到
注意:我为 Immerok 工作
【讨论】: