ApsaraMQ for Kafka は、完全に管理された、O&M 不要のインスタンス移行サービスを提供します。 セルフマネージド Apache Kafka クラスターから ApsaraMQ for Kafka インスタンスに、メタデータ（トピックおよびグループ構成）とメッセージデータを移行できます。 移行後、ApsaraMQ for Kafka インスタンスのメタデータは、セルフマネージド Apache 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 インスタンスに移行されます。
重要セルフマネージド Apache Kafka クラスターをインターネット経由で ApsaraMQ for Kafka インスタンスに移行する場合は、データを同期する前に、インスタンスのインターネットアクセスを有効にする必要があります。 インターネットアクセスを有効にする方法については、「（オプション）インターネットアクセスを有効にする」をご参照ください。
ステップ 1：仕様の評価
ApsaraMQ for Kafka は、クラスタートラフィック、ディスク容量、ディスクタイプなど、セルフマネージド Apache Kafka クラスターの情報に基づいて、移行タスクに必要な ApsaraMQ for Kafka インスタンスの仕様を評価および推奨する仕様評価機能を提供します。 詳細については、「仕様を評価する」をご参照ください。
ステップ 2：インスタンスの購入
評価されたインスタンス仕様に基づいて ApsaraMQ for Kafka インスタンスを購入し、デプロイします。 詳細については、「インターネットおよび VPC 接続インスタンスの購入とデプロイ」をご参照ください。
ステップ 3：移行タスクの作成
ApsaraMQ for Kafka コンソール にログオンします。 概要 ページの リソースの分布 セクションで、管理する ApsaraMQ for Kafka インスタンスが存在するリージョンを選択します。
左側のナビゲーションウィンドウで、Migration をクリックします。 表示されるページで、クラウドに移行 タブをクリックします。
クラウドに移行 タブで、タスクの作成 をクリックします。
クラウド移行タスクを作成する ウィザードで、パラメーターを構成します。
基本情報の設定 ステップで、タスク名 パラメーターと 対象インスタンス パラメーターを構成し、次へ をクリックします。
ソースサービスの設定 ステップで、ソースインスタンスタイプ パラメーターを インターネット (IDC またはクロスクラウドインスタンス) に設定し、その他のパラメーターを構成します。 次に、次へ をクリックします。
パラメーター
説明
例
アクセスポイント
セルフマネージド Apache Kafka クラスターのパブリックエンドポイント。
192.168.XX.XX:9092
セキュリティプロトコル
セルフマネージド Apache Kafka クラスターのセキュリティプロトコル。 有効な値：
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 プロトコルを使用する場合は、このパラメーターを構成してサーバー ID を検証し、中間者攻撃を防ぐことができます。 このフィールドには、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
ターゲットサービスの設定 ステップで、作成 をクリックします。
移行 ページの [クラウド移行] タブで、インスタンス ドロップダウンリストから宛先インスタンスを選択し、作成した移行タスクを見つけて、操作 列の デプロイ をクリックします。
移行タスクが作成されると、移行 ページの [クラウド移行] タブで、タスクに対応する ステータス 列が 実行中 になることがわかります。
ステップ 4：進捗状況の表示
移行 ページで、クラウドに移行 タブをクリックします。
管理するタスクを見つけ、同期の進行状況 を [アクション] 列でクリックします。
[トピックを選択] ドロップダウンリストの 同期の進行状況 パネルで、同期されたトピックを表示します。
[トピックを選択] ドロップダウンリストから表示するトピックを選択し、トピックの各パーティションのデータ同期ステータスを確認します。
次の手順
ApsaraMQ for Kafka インスタンスの新しいコンシューマーグループを有効にして、インスタンス内のメッセージを消費します。
ApsaraMQ for Kafka インスタンスの新しいプロデューサーを有効にし、元々のプロデューサーをシャットダウンし、元々のコンシューマーグループがセルフマネージド Apache Kafka クラスタ内のメッセージを引き続き消費できるようにします。
セルフマネージド Apache Kafka クラスタ内のすべてのメッセージが元々のコンシューマーグループによって消費された後、それらとセルフマネージド Apache Kafka クラスタをシャットダウンします。