ApsaraMQ for Kafka:クラウドへの移行

移行プロセス

注意事項

• 移行タスク作成時に宛先インスタンスとしてサーバーレスではない ApsaraMQ for Kafka インスタンスを使用する場合、実行中のインスタンスで、エディションが Professional Edition (High Write) または Professional Edition (High Read)、かつメジャーバージョンが 2.2.0 以降であることを確認してください。

• Alibaba Cloud 上にデプロイされたセルフマネージド Apache Kafka クラスターのメタデータおよびメッセージデータを移行する場合は、セルフマネージド Apache Kafka クラスターと同じリージョンで ApsaraMQ for Kafka インスタンスを購入し、同じ VPC 内にデプロイしたうえで、VPC 内でメタデータおよびメッセージデータを移行することを推奨します。

• 本トピックでは、セルフマネージド Apache Kafka クラスターのメタデータおよびメッセージデータを、インターネットおよび VPC 接続対応の ApsaraMQ for Kafka インスタンスに移行します。

ステップ 1：仕様の評価

ApsaraMQ for Kafka には仕様評価機能があり、セルフマネージド Apache Kafka クラスターのトラフィック量、ディスク容量、ディスクタイプなどの情報をもとに、移行タスクに必要な ApsaraMQ for Kafka インスタンスの仕様を評価・推奨します。詳細については、「仕様の評価」をご参照ください。

ステップ 2：インスタンスの購入

評価されたインスタンスの仕様に基づいて ApsaraMQ for Kafka インスタンスを購入し、デプロイします。詳細については、「インターネットおよび VPC 接続対応インスタンスの購入とデプロイ」をご参照ください。

ステップ 3：移行タスクの作成

1. ApsaraMQ for Kafka コンソールにログインします。概要ページのリソース分布セクションで、管理対象の ApsaraMQ for Kafka インスタンスが配置されているリージョンを選択します。

2. 左側のナビゲーションウィンドウで、移行をクリックします。表示されたページで、クラウド移行タブをクリックします。

3. クラウド移行タブで、タスクの作成をクリックします。

4. クラウド移行タスクを作成するウィザードで、パラメーターを設定します。

   1. 基本情報の設定ステップで、タスク名および対象インスタンスを設定し、次へをクリックします。

   2. ソースサービスの設定ステップで、ソースインスタンスタイプをインターネット (IDC またはクロスクラウドインスタンス)に設定し、その他のパラメーターを設定します。その後、次へをクリックします。

• PLAINTEXT

• SASL_PLAINTEXT

  • SASL ユーザー名：SASL ユーザー名を入力します。

  • SASL パスワード：SASL パスワードを入力します。

  • Sasl_Mechanism：SASL 認証メカニズムを選択します。有効な値：PLAIN、SCRAM-SHA-256、SCRAM-SHA-512

• SASL_SSL

  • SASL ユーザー名：SASL ユーザー名を入力します。

  • SASL パスワード：SASL パスワードを入力します。

  • Sasl_Mechanism：SASL 認証メカニズムを選択します。有効な値：PLAIN、SCRAM-SHA-256、SCRAM-SHA-512

  • ssl truststore ファイル：証明書ファイルをアップロードします。

  • ssl truststore password：証明書パスワードを入力します。

  • ssl endpoint identification algorithm：サーバー証明書を検証するために使用するアルゴリズムを指定します。SSL プロトコルを使用して通信を行う場合、このパラメーターを設定することでサーバーのアイデンティティを検証し、中間者攻撃を防止できます。このフィールドには https、http、または空文字列を入力できます。

| PLAINTEXT タスク数| データ同期のタスク数です。有効な値：

• 1

• 6

• 12

| 12 sasl ユーザーの同期| セルフマネージド Apache Kafka クラスターの SASL ユーザーの構成データを ApsaraMQ for Kafka インスタンスに同期するかどうかを指定します。このパラメーターは、実行環境の設定をクリックした後に表示されます。デフォルト値：いいえ。| はい topic acls の同期| セルフマネージド Apache Kafka クラスター内のトピックにアタッチされたアクセス制御リスト (ACL) の構成データを ApsaraMQ for Kafka インスタンスに同期するかどうかを指定します。このパラメーターは、実行環境の設定をクリックした後に表示されます。デフォルト値：いいえ。

• はい：セルフマネージド Apache Kafka クラスター内のトピックにアタッチされた ACL の構成データが ApsaraMQ for Kafka インスタンスに同期されます。ACL の構成データをインスタンスに同期する前に、ApsaraMQ for Kafka インスタンス上に SASL ユーザーを作成する必要があります。

• いいえ：セルフマネージド Apache Kafka クラスター内のトピックにアタッチされた ACL の構成データは ApsaraMQ for Kafka インスタンスに同期されません。

| はい コンシューマーグループの同期| セルフマネージド Apache Kafka クラスターのコンシューマグループを ApsaraMQ for Kafka インスタンスに同期するかどうかを指定します。このパラメーターは、実行環境の設定をクリックした後に表示されます。デフォルト値：いいえ。| はい コンシューマーオフセットの同期| セルフマネージド Apache Kafka クラスターのコンシューマオフセットを ApsaraMQ for Kafka インスタンスに同期するかどうかを指定します。このパラメーターは、実行環境の設定をクリックし、コンシューマーグループの同期パラメーターをはいに設定した後に表示されます。デフォルト値：いいえ。| はい トピック| ApsaraMQ for Kafka インスタンスに同期するトピックです。このパラメーターを設定しない場合、セルフマネージド Apache Kafka クラスター内のすべてのトピックが同期されます。このパラメーターは、実行環境の設定をクリックした後に表示されます。| test-topic ローカルエンジン Topic として作成する| ApsaraMQ for Kafka インスタンスに同期する非ログ圧縮トピックです。作成されたトピックにローカル記憶域を使用させる場合は、このパラメーターを設定する必要があります。このパラメーターを設定しない場合、作成されたトピックはクラウドストレージを使用します。このパラメーターは、実行環境の設定をクリックした後に表示されます。| test-topic

1. ターゲットサービスの設定ステップで、作成をクリックします。

1. 移行ページのクラウド移行タブで、インスタンスドロップダウンリストから宛先インスタンスを選択し、作成した移行タスクを見つけ、操作列のデプロイをクリックします。

移行タスクが作成されると、移行ページのクラウド移行タブで、該当タスクのステータス列が実行中になります。

ステップ 4：進捗状況の確認

1. 移行ページで、クラウド移行タブをクリックします。

2. 管理対象のタスクを見つけ、操作列の同期の進行状況をクリックします。

3. 同期の進行状況パネルのトピックの選択ドロップダウンリストで、同期済みのトピックを確認します。

4. トピックの選択ドロップダウンリストから確認したいトピックを選択し、そのトピックの各パーティションのデータ同期ステータスを確認します。

次のステップ

1. ApsaraMQ for Kafka インスタンスに対して新しいコンシューマグループを有効化し、インスタンス内のメッセージを消費できるようにします。

2. ApsaraMQ for Kafka インスタンスに対して新しいプロデューサーを有効化し、元のプロデューサーを停止します。同時に、元のコンシューマグループによるセルフマネージド Apache Kafka クラスター内でのメッセージ消費を継続させます。

3. セルフマネージド Apache Kafka クラスター内のすべてのメッセージが元のコンシューマグループによって消費された後、元のコンシューマグループおよびセルフマネージド Apache Kafka クラスターを停止します。