フェイルバック

セカンダリクラスターをソース、プライマリクラスターをターゲットとし、開始位置を earliest に設定して、同一トピック名レプリケーション (コンソールで同じトピック名を保持) を使用して、新しい MSK レプリケーターを作成します。これにより、プライマリリージョンへのフェイルオーバー後にセカンダリクラスターに書き込まれたすべてのデータのコピーが開始されます。

Amazon CloudWatch で、新しいレプリケーターの MessageLag メトリクスを、すべてのデータがセカンダリからプライマリにレプリケートされたことを示す 0 に達するまでモニタリングします。

すべてのデータがレプリケートされたら、セカンダリクラスターに接続しているすべてのプロデューサーを停止し、プライマリクラスターに接続しているプロデューサーを起動します。

セカンダリクラスターに接続するコンシューマーがすべてのデータを処理したことを確認する0ために、MaxOffsetLagメトリクスが になるまで待ちます。「コンシューマーラグをモニタリングする」を参照してください。

すべてのデータが処理されたら、セカンダリリージョンのコンシューマーを停止し、プライマリクラスターに接続するコンシューマーを起動してフェイルバックを完了します。

セカンダリクラスターからプライマリにデータをレプリケートする最初のステップで作成したレプリケーターを削除します。

プライマリクラスターからセカンダリクラスターにデータをコピーする既存のレプリケーターのステータスが「RUNNING」で、Amazon CloudWatch のReplicatorThroughputメトリクスが より大きいことを確認します0。

フェイルバックの開始位置を Earliest として新しいレプリケーターを作成すると、セカンダリクラスターのトピック内のすべてのデータの読み取りが開始されることに注意してください。データ保持設定によっては、トピックにソースクラスターから取得されたデータが含まれる場合があります。MSK Replicator はこれらのメッセージを自動的にフィルタリングしますが、セカンダリクラスター内のすべてのデータに対してデータ処理および転送料金が発生します。ReplicatorBytesInPerSec を使用して、レプリケーターによって処理されたデータの合計を追跡できます。

セカンダリリージョンの MSK クラスターに接続しているすべてのプロデューサーとコンシューマーをシャットダウンします。

アクティブ/パッシブトポロジの場合は、セカンダリリージョンのクラスターからプライマリリージョンにデータをレプリケートしているレプリケーターを削除します。アクティブ/アクティブトポロジの場合は、レプリケーターを削除する必要はありません。

プライマリリージョンの MSK クラスターに接続しているプロデューサーを起動します。

アプリケーションでメッセージの順序付けが必要ない場合は、ワイルドカード演算子を使用して、ローカルトピックとレプリケートされたトピックの両方から読み取るプライマリ AWS リージョンでコンシューマーを起動します。アプリケーションでメッセージの順序付けが必要な場合は、まずレプリケートされたトピックに対してのみコンシューマーを起動し、遅延が 0 になるまで待ってから、ローカルトピックに切り替えます。

プライマリリージョンのクラスターからセカンダリリージョンのクラスターへの既存のレプリケーターが RUNNING 状態であり、 ReplicatorThroughputおよび レイテンシーメトリクスを使用して期待どおりに動作していることを確認します。