View a markdown version of this page

Amazon MSK クラスター間の移行 - Amazon Managed Streaming for Apache Kafka

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

Amazon MSK クラスター間の移行

Amazon MSK Replicator は、同じ AWS アカウント内の Amazon MSK クラスター間の移行をサポートします。クラスターの移行には同一トピック名レプリケーションを使用できますが、コンシューマーはダウンストリームに影響を与えることなく重複したメッセージを処理できる必要があります。これは、MSK Replicator が少なくとも 1 回のレプリケーションを提供するため、まれに重複したメッセージが発生する可能性があるためです。コンシューマーがこの要件を満たしている場合は、以下の手順に従ってください。

  1. レプリケーターの開始位置を Earliest に設定し、同一トピック名レプリケーション (コンソールで同じトピック名を保持) を使用して、古いクラスターから新しいクラスターにデータをレプリケートするレプリケーターを作成します。

  2. 新しいクラスターに対してクラスターレベルの設定とアクセス許可を設定します。MSK レプリケーターが自動的にコピーするため、トピックレベルの設定と「リテラルACLs を設定する必要はありません。

  3. すべてのデータがレプリケートされたことを示す 0 に達するまで、Amazon CloudWatch でMessageLagメトリクスをモニタリングします。

  4. すべてのデータがレプリケートされたら、プロデューサーが古いクラスターにデータを書き込まないようにします。

  5. これらのプロデューサーを再設定して新しいクラスターに接続し、起動します。

  6. 古いクラスターからデータを読み込んでいるコンシューマーの MaxOffsetLag メトリクスを、既存のすべてのデータが処理されたことを示す 0 になるまでモニタリングします。

  7. 古いクラスターに接続しているコンシューマーを停止します。

  8. コンシューマーを再設定して新しいクラスターに接続し、起動します。