View a markdown version of this page

計画外のフェイルオーバー - Amazon Managed Streaming for Apache Kafka

翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。

計画外のフェイルオーバー

プライマリ AWS リージョンにサービスイベントがあり、トラフィックをセカンダリリージョンに一時的にリダイレクトする場合は、予期しないフェイルオーバーを実行できます。MSK Replicator はデータを非同期的にレプリケートするため、計画外のフェイルオーバーが発生すると、データが失われる可能性があります。レプリケーションのモニタリング のメトリクスを使用して、メッセージの遅延を追跡できます。

Identical topic name replication

  1. プライマリリージョンのソース MSK クラスターに接続しているすべてのプロデューサーとコンシューマーをシャットダウンしてみます。このオペレーションは、そのリージョンの障害が原因で成功しない可能性があります。

  2. セカンダリ AWS リージョンのターゲット MSK クラスターに接続するプロデューサーとコンシューマーを起動します。MSK レプリケーターは読み取り ACLs やコンシューマーグループのオフセットなどのメタデータもレプリケートするため、プロデューサーとコンシューマーは中断した場所からシームレスに処理を再開します。

Prefixed topic name replication

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

  2. セカンダリ AWS リージョンでターゲット MSK クラスターに接続するプロデューサーを起動します。

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

  4. プライマリリージョンでサービスイベントが終了したら、新しい MSK レプリケーターを作成し、レプリケーターの開始位置を earliest に設定して、セカンダリリージョンの MSK クラスターからプライマリリージョンの MSK クラスターにデータをレプリケートします。開始位置を最早に設定しない場合、サービスイベント中に生成されたデータはコピーされません。