AWS Lambda 支持从 Kafka 事件源的时间戳开始

现在，在使用 Amazon Managed Streaming for Apache Kafka (MSK) 或自行管理的 Kafka 作为事件源时，AWS Lambda 支持从一个特定时间戳开始。以前，Kafka 事件源映射只能有“trim horizon”或“latest”起始位置。现在，借助从某个时间戳开始的功能，您可以在一个精确的时间点开始处理消息。这对于灾难恢复等情况非常有用，在这种情况下，您需要一个新的使用器来从之前中断的地方快速开始处理。

当 Kafka 事件源映射配置为从特定时间戳开始时，事件源映射将开始处理主题中的消息或指定时间戳之后的第一条消息。要使用此功能，请创建新的 Kafka 事件源映射，将“StartingPosition”设为 AT_TIMESTAMP，并将“StartingPositionTimestamp”设为所需的起始位置。“StartingPositionTimestamp”值的格式应为 Unix 时间秒。 请注意，在 Kafka 中，起始位置仅用于新的使用器组或现有使用器组指向无效（过期）的偏移的情况。如果未以其他方式配置特定的使用器组 ID，则新的 Kafka 事件源映射将生成新的使用器组 ID。

此功能不额外收费。您需要为连接到 Kafka 的事件源映射触发的 Lambda 调用付费。要了解更多信息，请参阅 Amazon MSK 和 Apache Kafka 的 Lambda 开发人员指南。