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

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

最終更新日:Dec 03, 2025

ApsaraMQ for Kafka は、フルマネージドのクラウド移行サービスを提供します。このサービスを使用して、自社運用クラスターまたはクロスクラウドインスタンスから ApsaraMQ for Kafka インスタンスにデータを同期できます。移行後、Topic やグループ構成などのメタデータ、およびソースクラスターからのメッセージデータが宛先インスタンスに同期されます。宛先インスタンスのメタデータはソースクラスターと一貫性が保たれ、継続的に更新されます。

前提条件

次の条件を満たす ApsaraMQ for Kafka インスタンスを購入し、デプロイ済みであること:

項目

説明

ステータス

Running

バージョン

メジャーバージョンは 2.2.0 または 2.6.2 で、マイナーバージョンは最新であること。

説明

インスタンスのステータスとバージョンは、ApsaraMQ for Kafka コンソールInstancesページのEnter Basic Informationセクションで確認できます。

制限事項

ApsaraMQ for Kafka は、クラウド移行タスクに次の制限を課します:

項目

制限

数量

単一のインスタンスは、最大 20 個の移行タスクをサポートします。クラウド移行タスクとコネクタタスクは、単一インスタンス上のリソースを共有します。

仕様タイプ

  • Serverless インスタンス

  • サーバーレス以外のインスタンス: Professional Edition (High Write) または Professional Edition (High Read)

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

オープンソースバージョンは 1.0.0 以降である必要があります。

課金

ApsaraMQ for Kafka のクラウド移行コンポーネントはパブリックプレビュー段階にあり、ApsaraMQ for Kafka インスタンスから独立しています。そのため、ApsaraMQ for Kafka サービスに対して料金は発生しません。Alibaba Cloud は、この移行に対してサービスレベルアグリーメント (SLA) を提供しません。クラウド移行が依存する他のプロダクトの SLA および課金に関する情報については、それらのプロダクトのドキュメントをご参照ください。

環境要件

クラウド移行機能を使用して、インターネット経由で接続された自社運用インスタンスから ApsaraMQ for Kafka インスタンスにデータを同期する場合、または VPC 内の ApsaraMQ for Kafka インスタンスから別の VPC 内の ApsaraMQ for Kafka インスタンスにリージョンをまたいでデータを同期する場合は、宛先インスタンスのインターネットアクセスを有効にし、インターネット経由でデータを同期する必要があります。詳細については、「(任意) インターネットアクセスを有効にする」をご参照ください。

ある VPC 内のインスタンスから別の VPC 内の ApsaraMQ for Kafka インスタンスにデータを同期するには、中国 (杭州) および中国 (成都) リージョンでは VPC が自動的に接続されます。他のリージョンでは、手動で VPC を接続する必要があります。詳細については、「リージョン間の VPC 接続」をご参照ください。

パブリックネットワークアクセスの有効化 (任意)

クラウド移行機能を使用して、リージョンをまたいで他の Alibaba Cloud サービスまたはパブリックネットワークエンドポイントにアクセスする場合は、パブリックネットワークアクセスを有効にします。

  1. ApsaraMQ for Kafka インスタンスがデプロイされている VPC 用に NAT Gateway を作成します。

    詳細については、「インターネット NAT Gateway」をご参照ください。

  2. NAT Gateway に Elastic IP アドレス (EIP) を関連付けます。

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

  3. VPC 内で ApsaraMQ for Kafka インスタンスが使用する vSwitch 用に SNAT エントリを作成します。

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

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

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

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

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

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

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

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

      • ソースインスタンスタイプVPC インスタンス (クラウド自作インスタンスと VPC ネットワーク接続) に設定した場合は、以下のパラメーターを設定します。

        パラメーター

        説明

        ソースリージョン

        ソースインスタンスのリージョンを選択します。

        China (Hangzhou)

        アクセスポイント

        ソースインスタンスのエンドポイント。

        192.168.XX.XX:9092

        [VPC ID]

        ソースインスタンスがデプロイされている VPC の ID。このパラメーターはソースインスタンスの VPC で自動的に入力されるため、設定する必要はありません。

        vpc-test-c****

        [vSwitch ID]

        ソースインスタンスの vSwitch の ID。

        vsw-bp1gbjqsf53og****

        セキュリティグループ

        ソースインスタンスのセキュリティグループを選択します。

        alikafka_pre-cn-7mz2****

        セキュリティプロトコル

        ソースインスタンスのセキュリティプロトコルを選択します。

        • 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 プロパティです。SSL 通信では、このパラメーターを使用してサーバー ID を認証し、中間者攻撃を防ぐことができます。https、http、または空の文字列を入力できます。

        PLAINTEXT

        タスク数

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

        • 1

        • 6

        • 12

        12

        sasl ユーザーの同期

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

        はい

        topic acls の同期

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

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

        • いいえ:Topic の ACL 情報をソースインスタンスから宛先インスタンスへ同期しません。

        はい

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

        ソースインスタンスから宛先インスタンスに使用者グループを同期して作成するかどうかを指定します。このパラメーターは、実行環境の設定 をクリックすると表示されます。デフォルト値ははいです。

        はい

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

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

        はい

        トピック

        ソースインスタンスから宛先インスタンスに同期する Topic です。空欄のままにすると、すべての Topic が同期されます。このパラメーターは、実行環境の設定 をクリックすると表示されます。

        test-topic

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

        宛先インスタンスに移行する非コンパクト Topic です。これらの Topic で Local エンジンを使用する場合は、その名前をここに入力します。このフィールドを空白のままにした場合、Topic は Cloud エンジンを使用するように作成されます。このパラメーターは、 実行環境の設定 をクリックすると表示されます。

        test-topic

      • ソースインスタンスタイプインターネット (IDC またはクロスクラウドインスタンス) に設定した場合は、次のパラメーターを設定します。

        パラメーター

        説明

        アクセスポイント

        ソースインスタンスのエンドポイント。

        192.168.XX.XX:9092

        セキュリティグループ

        ソースインスタンスのセキュリティグループを選択します。

        alikafka_pre-cn-7mz2****

        セキュリティプロトコル

        ソースインスタンスのセキュリティプロトコルを選択します。

        • 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 プロパティです。 SSL 通信では、このパラメーターを使用してサーバー ID を認証し、中間者攻撃を防ぐことができます。 https、http、または空の文字列を入力できます。

        PLAINTEXT

        タスク数

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

        • 1

        • 6

        • 12

        12

        sasl ユーザーの同期

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

        はい

        topic acls の同期

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

        • はい: ソースインスタンスから宛先インスタンスに Topic の ACL 情報を同期します。ソースインスタンスが自己管理型の場合、Topic の ACL を同期する前に、宛先インスタンスで SASL ユーザーを手動で作成する必要があります。

        • いいえ: ソースインスタンスから宛先インスタンスへ Topic の ACL 情報を同期しません。

        はい

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

        ソースインスタンスから宛先インスタンスに、使用者グループを同期して作成するかどうかを指定します。このパラメーターは、実行環境の設定をクリックすると表示されます。デフォルト値ははいです。

        はい

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

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

        はい

        トピック

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

        test-topic

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

        宛先インスタンスに移行する非コンパクト Topic です。これらの Topic で Local エンジンを使用する場合は、ここにその名前を入力します。この項目を空白のままにした場合、Topic は Cloud エンジンを使用するように作成されます。このパラメーターは、実行環境の設定 をクリックすると表示されます。

        test-topic

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

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

    移行 ページで、タスクのステータス実行中に変わると、タスクは正常にデプロイされます。

その他の操作

移行 ページで、インスタンス ドロップダウンリストからタスクが属するインスタンスを選択します。タスクリストで目的のタスクを見つけ、[アクション] 列で他の操作を実行します。

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

  • 同期の進捗状況の表示:同期の進行状況 をクリックし、進捗を表示したい Topic を選択して [OK] をクリックします。

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

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

  • タスクの一時停止または有効化: 詳細 > 一時停止 または 詳細 > 有効にする を選択し、[プロンプト] ダイアログボックスで [確認] をクリックします。

  • タスクの削除: 詳細 > 削除 を選択します。[プロンプト] ダイアログボックスで、[確認] をクリックします。