ApsaraMQ for Kafka:クラウド移行

課金

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 サービスまたはパブリックエンドポイントに クロスリージョン でアクセスするには、インターネットアクセス を有効にする必要があります。

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

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

2. Elastic IP アドレス を NAT ゲートウェイ に関連付けます。

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

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

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

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

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

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

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

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

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

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

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

        [パラメーター]	[説明]	[例]
        [ソースリージョン]	移行元 インスタンス の リージョン を選択します。	[China (Hangzhou)]
        [アクセスポイント]	移行元インスタンスのエンドポイント。任意のブローカーのアドレスを 1 つ入力するだけです。システムはクラスター内のすべてのノードを自動的に検出して接続します。	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 の同期]	データ移行中に topic ACL を同期するかどうかを指定します。このパラメーターは、実行環境の設定 をクリックすると表示されます。デフォルト値は はい です。 [はい]: ソース instance から宛先 instance に topic ACL を同期します。 ソース instance が self-managed cluster の場合、topic ACL を同期するには、宛先 instance に SASL ユーザーを手動で作成する必要があります。 [いいえ]: ソース instance から宛先 instance に topic の ACL を同期しません。	[はい]
        [コンシューマーグループの同期]	データ移行中にソース インスタンス から宛先 インスタンス へ コンシューマーグループ を同期するかどうかを決定します。このパラメーターは、実行環境の設定 をクリックすると表示されます。デフォルト値は はい です。	[はい]
        [コンシューマーオフセットの同期]	データ移行中に、移行元の instance から移行先の instance へ consumer offset を同期するかどうかを決定します。このパラメーターは、実行環境の設定 をクリックし、コンシューマーグループの同期 を はい に設定した場合にのみ表示されます。デフォルト値は はい です。	[はい]
        トピック	宛先 instance に同期するソース instance 上の topic。このパラメーターを空欄にした場合、すべての topic が同期されます。このパラメーターは、実行環境の設定 をクリックすると表示されます。	test-topic
        [ローカルエンジン Topic として作成する]	宛先のinstance上にlocal storageを使用して作成する非圧縮のtopicを指定します。このパラメーターを空のままにすると、topicはcloud storageで作成されます。このパラメーターは、実行環境の設定をクリックすると表示されます。	test-topic

        警告

        トピックごとに移行タスクを 1 つだけ設定してください。複数の移行タスクが同じ移行先トピックにデータを同期すると、重複データが書き込まれます。移行タスクは重複排除をサポートしていません。

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

        [パラメーター]	[説明]	[例]
        [アクセスポイント]	移行元インスタンスのエンドポイント。任意のブローカーのアドレスを 1 つ入力するだけです。システムはクラスター内のすべてのノードを自動的に検出して接続します。	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 ユーザー情報を移行先の instance に同期するかどうかを指定します。このパラメーターは、実行環境の設定 をクリックすると表示されます。デフォルト値は はい です。	[はい]
        [topic acls の同期]	データ移行中に topic ACL を同期するかどうかを指定します。このパラメーターは、実行環境の設定 をクリックした後に表示されます。デフォルト値は はい です。 [はい]：ソース インスタンス から宛先 インスタンス に トピック ACL を同期します。ソース インスタンス が 自己管理型クラスター の場合、トピック ACL を同期するには、宛先 インスタンス で SASL ユーザーを手動で作成する必要があります。 [いいえ]：ソース instance から宛先 instance に topic の ACL を同期しません。	[はい]
        [コンシューマーグループの同期]	データ移行中にソース インスタンス から宛先 インスタンス へ コンシューマーグループ を同期するかどうかを指定します。このパラメーターは、実行環境の設定 をクリックすると表示されます。デフォルト値は はい です。	[はい]
        [コンシューマーオフセットの同期]	データ移行中にソースインスタンスから宛先インスタンスに consumer offset を同期するかどうかを決定します。このパラメーターは、実行環境の設定 をクリックし、コンシューマーグループの同期 を はい に設定した場合にのみ表示されます。デフォルト値は はい です。	[はい]
        トピック	ソースインスタンスから宛先インスタンスに同期するトピックです。このパラメーターを空欄にした場合、すべてのトピックが同期されます。このパラメーターは、 実行環境の設定 をクリックすると表示されます。	test-topic
        [ローカルエンジン Topic として作成する]	宛先 instance に local storage を使用して作成する非圧縮の topic を指定します。このパラメーターが空の場合、topic は cloud storage を使用して作成されます。このパラメーターは、実行環境の設定 をクリックした後に表示されます。	test-topic

        警告

        トピックごとに移行タスクを 1 つだけ設定してください。複数の移行タスクが同じ移行先トピックにデータを同期すると、重複データが書き込まれます。移行タスクは重複排除をサポートしていません。

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

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

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

その他の操作