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

ApsaraMQ for Kafka:セルフマネージド Apache Kafka クラスタを ApsaraMQ for Kafka インスタンスに移行する

最終更新日:Jun 10, 2025

セルフマネージド Apache Kafka クラスターのコストを削減し、スケーラビリティを高め、信頼性を向上させる場合は、クラスターを ApsaraMQ for Kafka インスタンスに移行できます。 ApsaraMQ for Kafka は、デプロイやメンテナンスを必要とせずにビジネス開発に集中できる、フルマネージドのメンテナンスフリーのサービスです。

使用上の注意

  • 移行が完了した後、セルフマネージド Apache Kafka クラスタのソース トピックとグループは削除されません。代わりに、宛先 ApsaraMQ for Kafka インスタンスに同じ構成の新しいトピックとグループが作成されます。

  • ビジネス要件に基づいて、メッセージデータとオフセット情報を移行するかどうかを選択できます。

ソリューションの説明

セルフマネージド Apache Kafka クラスターを ApsaraMQ for Kafka インスタンスに移行する場合は、元のコンシューマーを使用して、元のクラスターにキューイングされているすべてのメッセージを消費する必要があります。プロデューサーとコンシューマーはクラスターにデプロイされます。クラスターにデプロイされているサーバーを 1 つずつ移行できます。移行プロセスは、上位層のサービスには影響しません。セルフマネージド Apache Kafka クラスターを ApsaraMQ for Kafka インスタンスに移行するメリットについては、「メリット」をご参照ください。

次の図は、セルフマネージド Apache Kafka クラスタを ApsaraMQ for Kafka インスタンスに移行する方法を示しています。

ApsaraMQ for Kafka は、次のソリューションを提供します。

項目

クラウド移行

メタデータのインポート

ツールによる移行

移行方法

ApsaraMQ for Kafka コンソールで移行タスクを作成することにより、データが移行されます。ほとんどの場合、この方法を使用してデータを移行することをお勧めします。

kafka-migration-assessment.jar ツールを使用してデータを JSON ファイルとしてエクスポートし、ApsaraMQ for Kafka コンソールでメタデータインポートタスクを作成することにより、データを移行します。

説明

セルフマネージド Apache Kafka クラスターがインターネットアクセスをサポートしていない場合は、この方法を使用してデータを移行できます。

kafka-migration-assessment.jar または MirrorMaker ツールを使用してデータを移行します。

移行コンテンツ

  • Topic

  • グループ

  • メッセージデータとオフセット情報

  • Topic にアタッチされているアクセス制御リスト ( ACL )

    移行前に、ApsaraMQ for Kafka コンソールで SASL ユーザーを作成する必要があります。

  • Topic

  • グループ

  • kafka-migration-assessment.jar

    • Topic

    • グループ

  • MirrorMaker

    • メッセージデータとオフセット情報

移行プロセス

  1. セルフマネージド Apache Kafka クラスターのパブリックエンドポイントを取得します。

  2. ApsaraMQ for Kafka コンソールでクラウド移行タスクを作成します。

  3. ApsaraMQ for Kafka インスタンスでコンシューマーグループを起動して、インスタンスに送信されるメッセージを消費します。

  4. ApsaraMQ for Kafka インスタンスでプロデューサーを起動し、セルフマネージド Apache Kafka クラスターのプロデューサーを終了してから、元のコンシューマーグループを使用して、セルフマネージド Apache Kafka クラスターにキューイングされているメッセージを消費します。

  5. セルフマネージド Apache Kafka クラスターのすべてのメッセージが元のコンシューマーグループによって消費された後、コンシューマーグループとセルフマネージド Apache Kafka クラスターを終了します。

  1. 移行ツールを使用して、セルフマネージド Apache Kafka クラスターのデータを ApsaraMQ for Kafka インスタンスに移行します。

  2. ApsaraMQ for Kafka インスタンスでコンシューマーグループを起動して、インスタンスに送信されるメッセージを消費します。

  3. ApsaraMQ for Kafka インスタンスでプロデューサーを起動し、セルフマネージド Apache Kafka クラスターのプロデューサーを終了してから、元のコンシューマーグループを使用して、セルフマネージド Apache Kafka クラスターにキューイングされているメッセージを消費します。

  4. セルフマネージド Apache Kafka クラスターのすべてのメッセージが元のコンシューマーグループによって消費された後、コンシューマーグループとセルフマネージド Apache Kafka クラスターを終了します。

参照