ApsaraMQ for RocketMQ:自己管理型 Apache RocketMQ クラスターの ApsaraMQ for RocketMQ への移行

移行元クラスターの要件

移行元の Apache RocketMQ クラスターは、以下の要件を満たす必要があります。満たさない場合は、してください。

宛先インスタンスの制限

完全なリストについては、「クォータと制限」をご参照ください。

SDK の互換性

Remoting SDK は、以下の Maven 依存関係とエンドポイント形式を使用します。

<dependency>
    <groupId>org.apache.rocketmq</groupId>
    <artifactId>rocketmq-client</artifactId>
    <version>{version}</version>
</dependency>

producer.setNamesrvAddr("xxx:9876");
consumer.setNamesrvAddr("xxx:9876");

スケジュールされたメッセージとリトライメッセージ

移行元クラスターにスケジュールされたメッセージまたはリトライ待ちのメッセージが含まれているかどうかを確認してください。移行後、すべてのプロデューサーとコンシューマーの接続は ApsaraMQ for RocketMQ インスタンスに切り替わります。移行元クラスターに残っているスケジュールされたメッセージやリトライメッセージは消費されない可能性があります。移行元クラスターを廃止する前に、いくつかのコンシューマープロセスを実行し続けてこれらのメッセージを処理してください。

移行バッチの計画

移行ツールは、バッチ操作、カナリアリリース、およびロールバックを伴うトピックごとの移行をサポートしており、各変更の影響範囲を縮小します。

1. トピックの選択とバッチの計画：移行するトピックを特定し、バッチにグループ化します。重要度の低いビジネストピックから始めます。

2. 上流および下流チームとの調整：選択したトピックを使用するすべてのプロデューサーおよびコンシューマーアプリケーションに通知します。すべてのアプリケーションはエンドポイントを更新する必要があります。

移行ツールがアクセスするもの

移行ツールは、移行元クラスターから以下の情報にのみアクセスします (最小権限)：

• トピックメタデータ

• コンシューマーグループメタデータ

• トピックの動的ルーティング登録

• コンシューマー接続とメッセージ蓄積状況

このツールは、他のクラスターデータにアクセスしたり、移行元クラスターに設定を書き込んだりすることはありません。

操作手順

1. ApsaraMQ for RocketMQ コンソールにログインします。

2. 上部のナビゲーションバーで、移行元クラスターと宛先インスタンスの両方が配置されているリージョンを選択します。左側のナビゲーションウィンドウで、RocketMQ Copilot > クラウドへの移行 を選択します。

3. クラウドへの移行 ページで、タスクの作成 をクリックします。

4. 移行タスクの作成 パネルで、次の表で説明するパラメーターを設定し、OK をクリックします。

5. 移行ウィザードの ネットワーク設定 ステップで、移行元の Apache RocketMQ クラスターのネットワーク詳細を入力し、ネットワークの構成 をクリックします。

6. ネットワーク構成が完了するのを待ってから、次へ をクリックします。

パラメーターリファレンス

操作手順

1. メタデータ移行 ステップで、トピックメタデータ タブをクリックします。

2. リストからトピックを選択し、ドロップダウンリストから正しい メッセージタイプ を選択して、確認してインポート をクリックします。一度に複数のトピックをインポートするには、それらを選択して バッチインポート をクリックします。

   重要

   Apache RocketMQ 4.x では、トピックレベルでメッセージタイプが定義されていません。ApsaraMQ for RocketMQ は、割り当てたメッセージタイプがトピック内の実際のメッセージと一致することを検証します。アプリケーションロジックに基づいてタイプを選択してください。誤ったタイプを選択すると、移行後にメッセージの送受信に失敗します。メッセージタイプが不明な場合は、してください。

3. グループメタデータ タブをクリックします。コンシューマーグループを選択し、ドロップダウンリストから正しい 消費順序 を選択して、確認してインポート をクリックします。一度に複数のグループをインポートするには、それらを選択して バッチインポート をクリックします。

   重要

   Apache RocketMQ 4.x SDK では、メッセージの消費順序はクライアント側で指定されます。ApsaraMQ for RocketMQ 5.x では、ブローカーがグループレベルで消費順序を制御します。アプリケーションの要件に基づいて順序を選択してください。順序が正しくないと、消費例外が発生します。不明な場合は、してください。

4. この移行バッチのすべてのトピックとグループがインポートされていることを確認してから、次へ をクリックします。

次に進む前に

• エンドポイントを変更した後、各アプリケーションを再起動して宛先インスタンスに接続します。

• すべてのプロデューサーおよびコンシューマーアプリケーションがエンドポイントを更新していることを確認してください：

  • 切り替えないプロデューサー：一部のメッセージの送信に失敗します。

  • 切り替えないコンシューマー：メッセージが蓄積され、消費できなくなります。

エンドポイント変更の例

producer.setNamesrvAddr("192.168.XX.XX:9876");
consumer.setNamesrvAddr("192.168.XX.XX:9876");

producer.setNamesrvAddr("rmq-cn-pe334******-vpc.cn-hangzhou.rmq.aliyuncs.com:8080");
// vipChannelEnabled のデフォルトは false です。true に設定されている場合は、この行をコメントアウトしてください。
// producer.setVipChannelEnabled(false);

consumer.setNamesrvAddr("rmq-cn-pe334******-vpc.cn-hangzhou.rmq.aliyuncs.com:8080");
// vipChannelEnabled のデフォルトは false です。true に設定されている場合は、この行をコメントアウトしてください。
// consumer.setVipChannelEnabled(false);

producer.setNamesrvAddr("rmq-cn-pe334******-vpc.cn-hangzhou.rmq.aliyuncs.com:8080");
// vipChannelEnabled のデフォルトは true です。false に設定してください。
producer.setVipChannelEnabled(false);

consumer.setNamesrvAddr("rmq-cn-pe334******-vpc.cn-hangzhou.rmq.aliyuncs.com:8080");
// vipChannelEnabled のデフォルトは true です。false に設定してください。
consumer.setVipChannelEnabled(false);

ClientConfiguration clientConfiguration = ClientConfiguration.newBuilder()
            .setEndpoints("192.168.XX.XX:9876")
            .setCredentialProvider(sessionCredentialsProvider)
            .build();

ClientConfiguration clientConfiguration = ClientConfiguration.newBuilder()
            .setEndpoints("rmq-cn-pe334******-vpc.cn-hangzhou.rmq.aliyuncs.com:8080")
            .setCredentialProvider(sessionCredentialsProvider)
            .build();

操作手順

すべてのアプリケーションがエンドポイントを更新して再起動した後、エンドポイントの変更 ステップで 次へ をクリックします。

次に進む前に

• 各ステージで、次に進む前にメッセージが正常に送受信されていることを確認してください。問題が発生した場合は、前のステージにロールバックしてトラブルシューティングを行ってください。

• 移行タスクを完了する前に、移行されたすべてのトピックのトラフィックを切り替え、正常な動作を確認してください。タスクが完了としてマークされた後、トラフィック切り替え設定は変更できません。

トラフィック切り替えステージ

各トピックは、以下の 4 つのステージを進行します。

各ステージのトラフィックトポロジー：

ステージ	トポロジー
移行元クラスターでの読み取りと書き込み
移行元クラスターでの書き込み、両クラスターでの読み取り
宛先クラスターでの書き込み、両クラスターでの読み取り
宛先クラスターでの読み取りと書き込み

各ステージでの検証チェック

操作手順

1. メッセージ移行 ステップで、移行するトピックを選択し、その検証ステータスを確認します。

   • チェック合格：次のステップに進みます。

   • 不合格：チェック結果に基づいてトラブルシューティングを行い、再検証 をクリックしてチェックが合格するまで繰り返します。

   • 不合格だが、ブロッキングではないことを確認済み：チェックを無視 をクリックして進みます。

2. 操作 列で、トラフィックの切り替え をクリックします。

3. 確認ダイアログで、OK をクリックします。

4. トラフィック切り替えステージ が 宛先クラスターでの読み取りと書き込み を表示するまで、各ステージでステップ 1 から 3 を繰り返します。

5. すべてのトピックが完全に切り替えられたら、ページ下部の 移行済み をクリックします。

追加操作

メッセージ移行 ページでは、以下の操作が利用できます。

• ロールバック

  • 前のステージにロールバック：トピックを移行が正常に機能していた最後のステージに戻します。再度進む前にトラブルシューティングを行ってください。

  • 初期ステージにロールバック：元のルーティング状態に戻します。これは緊急のトラブルシューティングにのみ使用してください。

    説明

    初期ステージにロールバックすると、以前のステージで生成された未消費のメッセージが遅延したり、処理できなくなったりする可能性があります。

• トピックの作成：メタデータ移行中にトピックが選択されなかった場合、宛先の ApsaraMQ for RocketMQ 5.x インスタンスで直接作成します。

• バッチトラフィック切り替え / バッチロールバック：一度に複数のトピックのトラフィックを切り替えたり、ロールバックしたりします。両方の操作は、同じトラフィック切り替えステージにあるトピックにのみ適用されます。