投稿日: Jun 21, 2023
AWS Lambda では、Amazon Managed Streaming for Apache Kafka (MSK) またはセルフマネージド Kafka をイベントソースとして使用する場合に、特定のタイムスタンプからの開始をサポートするようになりました。これまで、Kafka のイベントソースマッピングにはトリムホライズンまたは最新の開始位置しか指定できませんでした。タイムスタンプから開始できるようになったため、特定の時点でメッセージの処理を開始できます。この機能は、ディザスタリカバリのように、以前に中断したところからすぐに処理を開始するために新しいコンシューマーが必要な場合に便利です。
Kafka イベントソースマッピングが特定のタイムスタンプから開始するように設定されている場合、イベントソースマッピングは、指定されたタイムスタンプの時点またはそれ以降の最初のメッセージからトピック内のメッセージの処理を開始します。この機能を使用するには、新しい Kafka イベントソースマッピングを作成し、StartingPosition を AT_TIMESTAMP に設定して、StartingPositionTimestamp を目的の開始位置に設定します。開始位置のタイムスタンプは Unix タイム秒の形式にする必要があります。 Kafka では、開始位置は新しいコンシューマーグループか、既存のコンシューマーグループが無効な (期限切れの) オフセットを指している場合にのみ使用されることにご注意ください。特定のコンシューマーグループ ID で特に設定されていない場合、新しい Kafka イベントソースマッピングは新しいコンシューマーグループ ID を生成します。
この機能に追加料金は発生しません。Kafka に接続されたイベントソースマッピングが Lambda 呼び出しをトリガーした際に、料金が発生します。詳細については Amazon MSK、Apache Kafka の Lambda 開発者ガイドを参照してください。