ApsaraMQ for Kafka は、データ同期機能により、ソース Kafka インスタンスからターゲット Kafka インスタンスへのメッセージデータの同期をサポートします。同一アカウントまたはクロスアカウントのシナリオで同期タスクを作成し、必要に応じて Topic、実行リソース、タスクの同時実行数、圧縮タイプ、メッセージオフセットリセット戦略を選択できます。データ同期機能は、データ配信、データバックアップ、ディザスタリカバリなど、2 つのインスタンス間の長期的なデータ転送向けに設計されています。
使用制限
この機能は現在、サポートチケットを通じて利用できます。必要な場合は、サポートチケットを提出してください。
課金
データ同期は CU に基づいて課金されます。詳細については、「CU 後払い」をご参照ください。
クロスアカウント/VPC でのデータ同期を行う場合、追加で VPC データ転送料金を支払う必要があります。詳細については、「VPC data transfer postpaid」をご参照ください。
前提条件
クロスアカウントデータ同期タスクを作成する前に、ソースインスタンスまたはターゲットインスタンスのアカウントで権限が付与されていることを確認してください。「権限管理」をご参照ください。権限付与後、権限を付与されたアカウントは、同期タスクの作成時に対応するインスタンスをソースまたはターゲットとして選択できます。
データ同期タスクの作成
ApsaraMQ for Kafka コンソールにログインします。
左側メニューで、 [Data Synchronization] を選択します。
[Data Synchronization] ページで、 [Create Task] をクリックします。
[Create Synchronization Task] ページで、指示に従って設定を完了してください。
ステップ 1：基本情報の設定
パラメーター | 説明 |
タスク名 | データ同期タスクの名前を入力します。後の運用保守とトラブルシューティングのために、ビジネス、ソースインスタンス、ターゲットインスタンスを識別できる名前を使用することを推奨します。 |
設定後、 [Next] をクリックします。
ステップ 2：ソースサービスの設定
パラメーター | 説明 |
クロスアカウントインスタンス | ソースインスタンスが別の Alibaba Cloud アカウントに属しているかどうかを選択します。クロスアカウントインスタンスを選択する場合、ソースインスタンスのアカウントは事前に権限管理で権限を付与しておく必要があります。 |
ソースクラスターインスタンス | データを読み取るソース Kafka インスタンスを選択します。 |
すべてのTopicを同期 | ソースインスタンスからすべての Topic を同期するかどうかを選択します。 [No] を選択した場合は、ページ上のプロンプトに従って同期する Topic を選択または入力します。 |
CU | 同期タスクのコンピューティングリソース仕様を選択します。通常、CU が高いほど同期能力が高くなります。詳細については、ページで利用可能な仕様をご参照ください。 |
タスク数 | データ同期タスクの数を選択します。 |
圧縮タイプ | ターゲットへの書き込み時のメッセージ圧縮タイプを選択します。ビジネスの互換性と圧縮効果に基づいて選択してください。 |
メッセージオフセットリセット戦略 | タスクのメッセージオフセットリセット戦略を選択します。 |
設定後、 [Next] をクリックします。
ステップ 3：ターゲットサービスの設定
パラメーター | 説明 |
ターゲットクラスター | 同期されたデータを受信するターゲット Kafka インスタンスを選択します。ターゲットインスタンスが別のアカウントに属している場合、ターゲットインスタンスのアカウントは事前に権限管理で権限を付与しておく必要があります。 |
設定を確認後、 [Create Synchronization Task] をクリックします。
次のステップ
タスクの作成後、[Data Synchronization] ページでタスクのステータス、同期の進捗、実行情報を確認できます。正式にトラフィックを切り替える前に、ターゲットインスタンスの Topic、メッセージの書き込みステータス、およびコンシューマーチェーンが期待どおりであることを確認することを推奨します。