すべてのプロダクト
Search
ドキュメントセンター

ApsaraMQ for Kafka:クラウド移行

最終更新日:Jul 02, 2026

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クラウド移行 機能には、以下の制限事項があります。

項目

制限

数量

インスタンス につき、最大 20 個の移行タスクを作成できます。クラウド移行コネクタ 機能は、単一の インスタンス 内でリソースを共有します。

エディションタイプ

  • Serverless インスタンス

  • 非 Serverless インスタンスの場合:Professional Edition (High Write) または Professional Edition (High Read)

ソースインスタンスのバージョン

オープンソースのバージョンは 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 KafkaApsaraMQ for Kafkaリージョン は自動 VPC 接続をサポートしています。他の リージョン では、手動で VPC を接続する必要があります。詳細については、「リージョンをまたいで VPC を接続する」をご参照ください。

インターネットアクセスを有効にする (オプション)

クラウド移行 機能を使用して、他の Alibaba Cloud サービスやパブリックエンドポイントに クロスリージョン でアクセスするには、インターネットアクセス を有効にする必要があります。

  1. Message Queue for Apache Kafka インスタンスをホストする VPC 1 用に NAT Gateway を作成します。

    詳細については、「Internet NAT Gateway」をご参照ください。

  2. NAT GatewayElastic IP アドレス を関連付けます。

    詳細については、「EIP をクラウドリソースに関連付ける」をご参照ください。

  3. VPC 1 の Message Queue for Apache Kafka インスタンスが使用する vSwitch の SNAT エントリを作成します。

    詳細については、「SNAT エントリの作成と管理」をご参照ください。

クラウド移行タスクの作成とデプロイ

  1. ApsaraMQ for Kafka コンソールにログインします。概要 ページで、リソースの分布 セクションでリージョンを選択します。

  2. 左側のナビゲーションウィンドウで、Migration をクリックし、次に クラウドに移行 をクリックします。

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

  4. クラウド移行タスクを作成する パネルで、以下のパラメーターを設定します。

    1. 基本情報の設定 タブで、タスク名 を指定し、対象インスタンス を選択して、次へ をクリックします。

    2. ソースサービスの設定 タブで、ソースサービスのパラメーターを設定し、次へ をクリックします。

      • ソースインスタンスタイプ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 を検証するために使用されるアルゴリズムで、中間者攻撃を防ぐのに役立ちます。httpshttp を入力するか、空白のままにすることができます。

        PLAINTEXT

        タスク数

        データ同期のタスク数を選択します。有効な値:

        • 1

        • 6

        • 12

        12

        sasl ユーザーの同期

        データ移行中に SASL ユーザーを同期するかどうかを指定します。 このパラメーターは、実行環境の設定 をクリックすると表示されます。 デフォルト値は はい です。

        はい

        topic acls の同期

        データ移行中に topic ACL を同期するかどうかを決定します。このパラメーターは、実行環境の設定 をクリックすると表示されます。デフォルト値は はい です。

        • はい: ソース インスタンスから送信先 インスタンスTopic ACL を同期します。ソース インスタンスセルフマネージドクラスターである場合、Topic ACL を同期するには、送信先 インスタンスで 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 を検証するために使用されるアルゴリズムで、中間者攻撃を防ぐのに役立ちます。httpshttp を入力するか、空白のままにすることができます。

        PLAINTEXT

        タスク数

        データ同期のタスク数を選択します。有効な値:

        • 1

        • 6

        • 12

        12

        sasl ユーザーの同期

        データ移行中に SASL ユーザー情報を送信先の インスタンス に同期するかどうかを指定します。このパラメーターは、実行環境の設定 をクリックすると表示されます。デフォルト値は はい です。

        はい

        topic acls の同期

        データ移行中に Topic ACL を同期するかどうかを決定します。このパラメーターは、実行環境の設定をクリックすると表示されます。デフォルト値ははいです。

        • はい: ソース インスタンスから送信先インスタンスTopic ACL を同期します。ソース インスタンスセルフマネージドクラスターの場合、Topic ACL を同期するには、送信先インスタンスに SASL ユーザーを手動で作成する必要があります。

        • いいえ: ソース instance から送信先 instancetopic ACL を同期しません。

        はい

        コンシューマーグループの同期

        データ移行中に、移行元のインスタンスから移行先のインスタンスコンシューマーグループを同期するかどうかを指定します。このパラメーターは、 実行環境の設定 をクリックすると表示されます。デフォルト値は はい です。

        はい

        コンシューマーオフセットの同期

        データ移行中にソース インスタンス から送信先 インスタンスコンシューマオフセット を同期するかどうかを指定します。このパラメーターは、実行環境の設定 をクリックし、コンシューマーグループの同期はい に設定した場合にのみ表示されます。デフォルト値は はい です。

        はい

        Topic

        ソースインスタンスから送信先インスタンスへ同期する Topic。 このパラメーターを空白のままにした場合、すべての Topic が同期されます。 このパラメーターは、実行環境の設定 をクリックすると表示されます。

        test-topic

        ローカルエンジン Topic として作成する

        送信先 インスタンス 上に ローカル記憶域 を使用して作成する非圧縮 トピック を指定します。この パラメーター を空欄にした場合、トピッククラウドストレージ を使用して作成されます。この パラメーター は、実行環境の設定 をクリックすると表示されます。

        test-topic

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

  5. タスクが作成された後、移行 ページで インスタンス ドロップダウンリストからターゲットインスタンスを選択し、インスタンスリストで作成したタスクを見つけ、操作 列の デプロイ をクリックします。

    移行 ページで、タスクの ステータス実行中 の場合、タスクは正常にデプロイされています。

その他の操作

移行 ページで、インスタンス ドロップダウンリストから関連する インスタンス を選択し、タスクを見つけ、操作 列のオプションを使用します。

  • タスク詳細の表示: 詳細 をクリックします。 タスク詳細ページでは、基本情報ソースサービスターゲットサービス、および 動作環境の設定 を確認できます。

  • 同期の進捗の表示: 同期の進行状況 をクリックし、表示する topic を選択してから、OK をクリックします。

  • タスク構成を変更するには、設定の変更 をクリックします。 表示されるパネルで、必要に応じてタスクパラメーターを変更します。

  • コンシューマオフセットのリセット: 詳細 > 消費位置のリセット を選択し、topic とリセットメソッドを設定してから、OK をクリックします。コンシューマオフセット のリセットの詳細については、「コンシューマオフセットのリセット」をご参照ください。

  • タスクを開始または停止するには、詳細 > 一時停止 または 詳細 > 有効にする を選択します。 次に、ヒント ダイアログボックスで OK をクリックします。

  • タスクを削除するには、詳細 > 削除を選択し、ヒント ダイアログボックスで OK をクリックします。