保持期間内のストリームを先頭から再処理する

取り込み方式、データの到着順、再処理、配信先、運用負荷の違いを整理する。

新しいコンシューマーの開始位置にTRIM_HORIZONを指定する

TRIM_HORIZONは保持されている最も古い位置から読み取りを始める指定である。

新しいコンシューマーの開始位置にLATESTを指定する

LATESTはコンシューマー開始時点以後の新しいレコードから読む指定である。

再処理前にKinesisのデータ保持期間を対象期間以上へ設定する

Kinesisの保持期間は、コンシューマーが過去データを読み直せる時間を決める。

ストリームを削除して同名で作り直す

ストリーム削除は保持データとシャードを失わせる破壊的操作である。