发布于: Jun 4, 2024
Amazon Lambda 现在针对 Amazon Managed Streaming for Apache Kafka（MSK）和自行管理的 Apache Kafka 事件源映射支持失败事件目标。失败事件目标使您的 Lambda 函数即使返回错误也能继续处理某主题的事件。
以前，如果 Amazon Lambda 函数无法处理 Kafka 消息，Lambda 函数将重试该记录，直到消息过期。这种方法可能会造成不必要的成本，并使错误处理更加复杂。对于失败事件目标，失败的事件批次将在重试几次后发送到 SQS、SNS 或 S3。这可确保 Lambda 函数不会在单个失败批次中停滞不前，并允许稍后重新驱动事件。超过 6MB 的 Kafka 消息也将发送到失败事件目标。选择 SQS 或 SNS 作为目标时，Lambda 将向目标发送包含偏移信息的元数据。选择 S3 作为目标时，Lambda 会将失败批次的调用记录发送到目标。
此功能现已在由光环新网运营的亚马逊云科技中国（北京）区域和由西云数据运营的亚马逊云科技中国（宁夏）区域推出。此功能默认处于关闭状态，无需另行付费即可使用，但需要支付与所需目标（SQS/SNS/S3）相关的费用。要了解更多信息，请参阅 Amazon MSK 的 Lambda 开发人员指南和 Apache Kafka 的 Lambda 开发人员指南。