Message Queue for Apache Kafka は、フルマネージドでメンテナンスフリーのクラウド移行サービスを提供し、セルフマネージドクラスターまたはクロスクラウドインスタンスと Message Queue for Apache Kafka インスタンス間のデータを同期します。移行が完了すると、ソースクラスターのメタデータ (Topic およびグループの構成情報) とメッセージデータがターゲットインスタンスに同期されます。ターゲットインスタンスのメタデータは、ソースクラスターのメタデータと一貫性が保たれ、継続的に更新されます。
前提条件
以下の要件を満たす ApsaraMQ for Kafka インスタンス を購入し、デプロイ済みであること。
|
項目 |
説明 |
|
ステータス |
Running |
|
バージョン |
2.2.0 または 2.6.2 の最新のマイナーバージョン。 |
Message Queue for Apache Kafka コンソールの Instances ページにある Enter Basic Information セクションで、お使いの instance のステータスとバージョンを確認できます。
制限事項
ApsaraMQ for Kafka の クラウド移行 機能には、以下の制限事項があります。
|
項目 |
制限 |
|
数量 |
各 |
|
エディションタイプ |
|
|
ソースインスタンスのバージョン |
オープンソースのバージョンは 1.0.0 以降である必要があります。 |
課金
ApsaraMQ for Kafka のクラウド移行コンポーネントは、2026 年 8 月 1 日から課金が開始されます。詳細については、「CU 従量課金」をご参照ください。
ネットワーク要件
クラウド移行機能を使用して、パブリックインターネット上のセルフマネージドインスタンスから ApsaraMQ for Kafka にデータを同期する場合、またはある VPC 内の ApsaraMQ for Kafka インスタンスから別の VPC 内の ApsaraMQ for Kafka インスタンスにクロスリージョンでデータを同期する場合は、インスタンスのインターネットアクセスを有効にしてから、インターネット経由でデータを同期する必要があります。詳細については、「インターネットアクセスを有効にする (オプション)」をご参照ください。
クラウド移行 機能を使用して、ある VPC 内の インスタンス から別の VPC 内の ApsaraMQ for Kafka インスタンス にデータを同期する必要がある場合、ApsaraMQ for Kafka と ApsaraMQ for Kafka の リージョン は自動 VPC 接続をサポートしています。他の リージョン では、手動で VPC を接続する必要があります。詳細については、「リージョンをまたいで VPC を接続する」をご参照ください。
インターネットアクセスを有効にする (オプション)
クラウド移行 機能を使用して、他の Alibaba Cloud サービスやパブリックエンドポイントに クロスリージョン でアクセスするには、インターネットアクセス を有効にする必要があります。
-
Message Queue for Apache Kafka インスタンスをホストする VPC 1 用に NAT Gateway を作成します。
詳細については、「Internet NAT Gateway」をご参照ください。
-
NAT GatewayにElastic IP アドレスを関連付けます。詳細については、「EIP をクラウドリソースに関連付ける」をご参照ください。
-
VPC 1 の Message Queue for Apache Kafka インスタンスが使用する vSwitch の SNAT エントリを作成します。
詳細については、「SNAT エントリの作成と管理」をご参照ください。
クラウド移行タスクの作成とデプロイ
ApsaraMQ for Kafka コンソールにログインします。概要 ページで、リソースの分布 セクションでリージョンを選択します。
左側のナビゲーションウィンドウで、Migration をクリックし、次に クラウドに移行 をクリックします。
-
クラウドに移行 タブで、タスクの作成 をクリックします。
-
クラウド移行タスクを作成する パネルで、以下のパラメーターを設定します。
-
基本情報の設定 タブで、タスク名 を指定し、対象インスタンス を選択して、次へ をクリックします。
-
ソースサービスの設定 タブで、ソースサービスのパラメーターを設定し、次へ をクリックします。
-
ソースインスタンスタイプでVPC インスタンス (クラウド自作インスタンスと VPC ネットワーク接続)を選択した場合は、以下のパラメーターを設定します。
パラメーター
説明
例
ソースリージョン
ソース
インスタンスのリージョンを選択します。China (Hangzhou)
アクセスポイント
ソース
インスタンスのエンドポイント。192.168.XX.XX:9092
VPC ID
この値は、ソース
インスタンスの VPC に基づいて自動的に入力され、変更できません。vpc-test-c****
vSwitch ID
ソース
インスタンスのvSwitch ID。vsw-bp1gbjqsf53og****
セキュリティグループ
ソース
インスタンスのセキュリティグループを選択します。alikafka_pre-cn-7mz2****
セキュリティプロトコル
ソース
インスタンスのセキュリティプロトコルを選択します。-
PLAINTEXT
-
SASL_PLAINTEXT
-
SASL ユーザー名:SASL ユーザー名を入力します。
-
SASL パスワード:SASL パスワードを入力します。
-
SASL メカニズム:SASL 認証メカニズム。有効な値:PLAIN、SCRAM-SHA-256、SCRAM-SHA-512。
-
-
SASL_SSL
-
SASL ユーザー名:SASL ユーザー名を入力します。
-
SASL パスワード:SASL パスワードを入力します。
-
SASL メカニズム: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 ユーザーの同期
データ移行中に SASL ユーザーを同期するかどうかを指定します。 このパラメーターは、実行環境の設定 をクリックすると表示されます。 デフォルト値は はい です。
はい
topic acls の同期
データ移行中に
topicACL を同期するかどうかを決定します。このパラメーターは、実行環境の設定 をクリックすると表示されます。デフォルト値は はい です。-
はい: ソース
インスタンスから送信先インスタンスにTopicACL を同期します。ソースインスタンスがセルフマネージドクラスターである場合、TopicACL を同期するには、送信先インスタンスで SASL ユーザーを手動で作成する必要があります。 -
いいえ:
Topicの ACL をソースインスタンスから送信先インスタンスに同期しません。
はい
コンシューマーグループの同期
データ移行中にソース
インスタンスから送信先インスタンスへコンシューマーグループを同期するかどうかを指定します。このパラメーターは、実行環境の設定 をクリックすると表示されます。デフォルト値は はい です。はい
コンシューマーオフセットの同期
データ移行中にソース
インスタンスから送信先インスタンスにコンシューマオフセットを同期するかどうかを指定します。このパラメーターは、実行環境の設定 をクリックし、コンシューマーグループの同期 を はい に設定した場合にのみ表示されます。デフォルト値は はい です。はい
Topic
ソース
インスタンスから送信先インスタンスに同期するTopic。このパラメーターを空欄にした場合、すべてのTopicが同期されます。このパラメーターは、実行環境の設定 をクリックすると表示されます。test-topic
ローカルエンジン Topic として作成する
どの非コンパクト化
トピックを、送信先インスタンス上でローカル記憶域を使用して作成するかを指定します。このパラメーターを空白のままにした場合、トピックはクラウドストレージで作成されます。このパラメーターは、実行環境の設定をクリックした後に表示されます。test-topic
-
-
ソースインスタンスタイプ に インターネット (IDC またはクロスクラウドインスタンス) を選択した場合は、以下のパラメーターを設定してください。
パラメーター
説明
例
アクセスポイント
ソース
インスタンスのエンドポイント。192.168.XX.XX:9092
セキュリティグループ
ソース
インスタンスのセキュリティグループを選択します。alikafka_pre-cn-7mz2****
セキュリティプロトコル
ソース
インスタンスのセキュリティプロトコルを選択します。-
PLAINTEXT
-
SASL_PLAINTEXT
-
SASL ユーザー名:SASL ユーザー名を入力します。
-
SASL パスワード:SASL パスワードを入力します。
-
SASL メカニズム:SASL 認証メカニズム。有効な値:PLAIN、SCRAM-SHA-256、SCRAM-SHA-512。
-
-
SASL_SSL
-
SASL ユーザー名:SASL ユーザー名を入力します。
-
SASL パスワード:SASL パスワードを入力します。
-
SASL メカニズム: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 ユーザーの同期
データ移行中に SASL ユーザー情報を送信先の
インスタンスに同期するかどうかを指定します。このパラメーターは、実行環境の設定 をクリックすると表示されます。デフォルト値は はい です。はい
topic acls の同期
データ移行中に
TopicACL を同期するかどうかを決定します。このパラメーターは、実行環境の設定をクリックすると表示されます。デフォルト値ははいです。-
はい: ソース
インスタンスから送信先インスタンスにTopicACL を同期します。ソースインスタンスがセルフマネージドクラスターの場合、TopicACL を同期するには、送信先インスタンスに SASL ユーザーを手動で作成する必要があります。 -
いいえ: ソース
instanceから送信先instanceにtopicACL を同期しません。
はい
コンシューマーグループの同期
データ移行中に、移行元の
インスタンスから移行先のインスタンスにコンシューマーグループを同期するかどうかを指定します。このパラメーターは、 実行環境の設定 をクリックすると表示されます。デフォルト値は はい です。はい
コンシューマーオフセットの同期
データ移行中にソース
インスタンスから送信先インスタンスへコンシューマオフセットを同期するかどうかを指定します。このパラメーターは、実行環境の設定 をクリックし、コンシューマーグループの同期 を はい に設定した場合にのみ表示されます。デフォルト値は はい です。はい
Topic
ソース
インスタンスから送信先インスタンスへ同期するTopic。 このパラメーターを空白のままにした場合、すべてのTopicが同期されます。 このパラメーターは、実行環境の設定 をクリックすると表示されます。test-topic
ローカルエンジン Topic として作成する
送信先
インスタンス上にローカル記憶域を使用して作成する非圧縮トピックを指定します。このパラメーターを空欄にした場合、トピックはクラウドストレージを使用して作成されます。このパラメーターは、実行環境の設定 をクリックすると表示されます。test-topic
-
-
-
ターゲットサービスの設定 タブで、作成 をクリックします。
-
-
タスクが作成された後、移行 ページで インスタンス ドロップダウンリストからターゲットインスタンスを選択し、インスタンスリストで作成したタスクを見つけ、操作 列の デプロイ をクリックします。
移行 ページで、タスクの ステータス が 実行中 の場合、タスクは正常にデプロイされています。
その他の操作
移行 ページで、インスタンス ドロップダウンリストから関連する インスタンス を選択し、タスクを見つけ、操作 列のオプションを使用します。
-
タスク詳細の表示: 詳細 をクリックします。 タスク詳細ページでは、基本情報、ソースサービス、ターゲットサービス、および 動作環境の設定 を確認できます。
-
同期の進捗の表示: 同期の進行状況 をクリックし、表示する
topicを選択してから、OK をクリックします。 -
タスク構成を変更するには、設定の変更 をクリックします。 表示されるパネルで、必要に応じてタスクパラメーターを変更します。
-
コンシューマオフセットのリセット: を選択し、
topicとリセットメソッドを設定してから、OK をクリックします。コンシューマオフセットのリセットの詳細については、「コンシューマオフセットのリセット」をご参照ください。 -
タスクを開始または停止するには、 または を選択します。 次に、ヒント ダイアログボックスで OK をクリックします。
-
タスクを削除するには、を選択し、ヒント ダイアログボックスで OK をクリックします。