发布于: Jun 4, 2024
现在，Amazon Lambda 支持在使用 Amazon Managed Streaming for Apache Kafka（MSK）或自行管理的 Kafka 作为事件源时从特定时间戳开始。以前，Kafka 事件源映射的起始位置只能是“trim horizon”或“latest”。现在，借助从某个时间戳开始的功能，您可以在一个精确的时间点开始处理消息。这对于灾难恢复等情况非常有用，在这种情况下，您需要一个新的使用器来从之前中断的地方快速开始处理。
当 Kafka 事件源映射配置为从特定时间戳开始时，事件源映射将开始处理主题中的消息或指定时间戳之后的第一条消息。要使用此功能，请创建新的 Kafka 事件源映射，将“StartingPosition”设为 AT_TIMESTAMP，并将“StartingPositionTimestamp”设为所需的起始位置。“StartingPositionTimestamp”值的格式应为 Unix 时间秒。 请注意，在 Kafka 中，起始位置仅用于新的使用器组或现有使用器组指向无效（过期）的偏移的情况。如果未以其他方式配置特定的使用器组 ID，则新的 Kafka 事件源映射将生成新的使用器组 ID。
Amazon Lambda 从 Kafka 事件的时间戳开始的触发器已在由光环新网运营的亚马逊云科技中国（北京）区域和由西云数据运营的亚马逊云科技中国（宁夏）区域推出。此功能不额外收费。您需要为连接到 Kafka 的事件源映射触发的 Lambda 调用付费。要了解更多信息，请参阅 Amazon MSK 的 Lambda 开发人员指南和 Apache Kafka 的 Lambda 开发人员指南。