发布于: Nov 16, 2023
AWS Lambda 现在支持 Amazon Managed Streaming for Apache Kafka (MSK) 和自主管理的 Apache Kafka 事件源映射的失败事件目标。有了失败事件目标，您的 Lambda 函数即使返回错误也能继续处理某主题的事件。
以前，如果 AWS Lambda 函数无法处理 Kafka 消息，Lambda 函数将重试该记录，直到消息过期。这种方法可能会造成不必要的成本并使错误处理复杂化。对于失败事件目标，失败的事件批次将在重试几次后发送到 SQS、SNS 或 S3。这可确保 Lambda 函数不会在单个失败批次中停滞不前，并允许稍后重新驱动事件。大于 6MB 的 Kafka 消息也将发送到失败事件目标。选择 SQS 或 SNS 作为目标时，Lambda 将向目标发送元数据，包含偏移信息。选择 S3 作为目标时，Lambda 会将失败批次的调用记录发送到目标。
此功能已在所有提供 Amazon MSK 或自主管理的 Apache Kafka 事件源映射的 AWS 区域推出。此功能默认情况下处于关闭状态，无需额外付费即可使用，但您需要支付与所需目标 (SQS/SNS/S3) 相关的费用。要了解更多信息，请参阅 Amazon MSK或 Kafka 的 Lambda 开发人员指南。