AWS Lambda 针对 Kafka 事件处理推出增强的错误处理能力

发布于: 2025年11月24日

AWS Lambda 针对 Amazon Managed Streaming for Apache Kafka（MSK）和自主管理的 Apache Kafka（SMK）事件源，推出增强的错误处理功能。这些功能让客户能够构建自定义重试配置，优化失败消息的重试方式，并将失败事件发送到 Kafka 主题作为失败事件目标位置，从而帮助客户构建具备有效的错误处理策略的弹性 Kafka 工作负载。

客户使用 Kafka 事件源映射（ESM）和 Lambda 函数来构建其任务关键型 Kafka 应用程序。Kafka ESM 通过使用指数回退重试事件，并将失败事件保留在 Amazon SQS、Amazon S3、Amazon SNS 等失败事件目标位置中，实现针对失败事件的有效错误处理。但是，客户需要定制化的错误处理方式，以满足严格的业务和性能要求。借助此次发布的功能，开发人员在使用 Kafka ESM 的预置模式时，能够对失败事件处理进行精确控制，并利用 Kafka 主题作为额外的失败事件目标位置。客户现在可以定义具体的重试次数限制和重试时间范围，并将超出这些限制的失败记录自动丢弃到客户指定的目标位置。他们现在还可以在批次中设置失败记录的自动重试，并增强其功能代码以报告单个失败消息，从而优化重试流程。

这项功能已在支持 AWS Lambda 针对 Kafka ESM 的预置模式的所有 AWS 商业区域推出。

要启用这些功能，请在 ESM API、AWS 管理控制台和 AWS CLI 中为您的 Kafka ESM 提供配置参数。要了解更多信息，请参阅 Lambda ESM 文档和 AWS Lambda 定价。