【问题标题】:Apache Flink 1.16 - DLQApache Flink 1.16 - DLQ
【发布时间】:2022-11-04 03:04:42
【问题描述】:

我有一个用于处理故障恢复和可重试的用例。我必须知道 Flink 中的 retryable 选项。但是在重试的最大尝试之后会发生什么。是转移到 DLQ 吗?如果是,我们是否有任何关于 DLQ 实施的文档。

【问题讨论】:

    标签: apache-flink


    【解决方案1】:

    如果已尝试最大重试次数,您的作业将失败。您将需要更新您的作业,以便它正确处理您的失败原因。例如,如果您在反序列化传入数据时遇到问题,您可以将该数据发送到 Apache Kafka 上的死信队列主题。

    这方面的一个例子可以在https://docs.immerok.cloud/docs/cookbook/creating-dead-letter-queues-from-and-to-apache-kafka-with-apache-flink/找到

    注意:我为 Immerok 工作

    【讨论】:

    • 谢谢你的cmets。让我试试看
    猜你喜欢
    • 1970-01-01
    • 1970-01-01
    • 2016-11-13
    • 2016-09-24
    • 1970-01-01
    • 1970-01-01
    • 2020-05-17
    • 1970-01-01
    • 1970-01-01
    相关资源
    最近更新 更多