本記事では、データ移行サービスを使用して、OceanBaseデータベース(MySQL互換モードおよびOracle互換モードを含む)のデータをKafkaに移行する方法について説明します。
注意
データ移行タスクが長期間非アクティブ状態(タスクステータスが 失敗、一時停止、または 完了 の場合)にあると、増分ログの保持期間などの影響でタスクが回復できない可能性があります。データ移行は、非アクティブ状態が7日間を超えるタスクを自動的に解放し、関連リソースを回収します。タスクに対してアラートを設定し、タスク関連の異常を速やかに処理することを推奨します。
背景
Kafkaは現在広く利用されている高性能な分散ストリーム処理プラットフォームです。データ移行サービスは、OceanBaseデータベースの2つの互換モードとKafkaデータソース間のリアルタイムデータ同期をサポートし、メッセージ処理能力を拡張します。リアルタイムデータウェアハウスの構築、データクエリ、レポートのフィルタリングなどの業務シナリオで広く利用されています。
Kafkaネットワーク接続タスクには、クラウドインスタンスKafkaネットワークとオンプレミスKafkaネットワークが含まれます。異なるタイプのネットワーク接続タスクのプロセスは以下のとおりです。
クラウドインスタンスKafkaネットワーク接続タスク

オンプレミスKafkaネットワーク接続タスク

前提条件
ソース側のOceanBaseデータベースのクラスタとテナントが作成済みであること。詳細については、クラスタの作成およびテナントの作成を参照してください。
ソース側のOceanBaseデータベースのMySQL互換モードとターゲット側のKafkaインスタンスに、データ移行専用のデータベースユーザーを作成し、関連する権限を付与していること。詳細については、データ移行ユーザー権限を参照してください。
制限事項
プロジェクトロールが プロジェクト所有者、プロジェクト管理者、または データサービス管理者 のユーザーのみが新規データ移行タスクの作成をサポートします。
ソースデータベースの操作制限
フル移行段階では、データベースまたはテーブル構造変更のDDL操作を実行しないでください。そうでない場合、データ移行タスクが中断する可能性があります。
現在、データ移行はKafka V0.9、V1.0、V2.x、OceanBaseデータベース(MySQLおよびOracle互換モードを含む)V2.x、V3.x、V4.xをサポートしています。
データ移行サービスはクラスタインスタンスのみをサポートしており、テナントインスタンスは現在サポートしていません。
データ移行サービスは、データベース名、テーブル名、列名がASCIIコードであり、特殊文字(.|"'`()=;/& および改行を含む)を含まないオブジェクトのみの移行をサポートしています。
データ移行の対象は物理テーブルのみをサポートし、その他のオブジェクトはサポートしていません。
データ移行プロセス中に、ソース側で移行範囲内のテーブル名を変更し、その後の名前が移行対象に含まれない場合、その部分のデータはターゲットKafkaインスタンスに同期されません。
注意事項
ノード間のクロックが同期していない場合、またはコンピュータ端末とサーバー間のクロックが同期していない場合、増分同期の遅延時間が正確でない可能性があります。
例えば、時計が標準時より進んでいると遅延時間が負の値になる可能性があります。時計が標準時より遅れていると遅延が発生する可能性があります。
ソース側がOceanBaseデータベースでDDL同期が有効なデータ移行タスクにおいて、ソース側のデータベーステーブルでRENAME操作が発生した場合は、増分同期でデータが失われないようタスクを再開始することを推奨します。
OceanBaseデータベースがV4.0.0からV4.3.xのバージョン(V4.2.5 BP1を除く)で、かつ増分同期が選択されている場合は、生成列にSTORED属性を設定してください。設定しない場合、増分ログには生成列の情報が保存されず、増分同期データに異常が発生する可能性があります。
更新対象行にLOB列が含まれる場合:
LOB列が更新列である場合、UPDATEまたはDELETE操作前のLOB列の値に依存しないでください。
現在、LOB列を使用して格納されているデータ型には、JSON、GIS、XML、UDT(ユーザー定義型)、およびLONGTEXT、MEDIUMTEXTなどの各種TEXTが含まれます。
LOB列が非更新列である場合、UPDATEまたはDELETE操作前後でLOB列の値はNULLになります。
タスクが予期せず中断され、中断点からの再開送信を行う場合、Kafkaインスタンスには一部の重複データ(直近1分以内のもの)が存在する可能性があるため、下流システムは重複除去機能を備えている必要があります。
OceanBaseデータベースのデータをKafkaに同期する際、ソース側で一意インデックスの作成ステートメントの実行に失敗した場合、KafkaはDDL作成ステートメントとDDL削除ステートメントを消費します。下流に伝送されたインデックス作成DDLの実行に失敗した場合は、この例外を無視してください。
データ移行タスクを新規作成する際に、増分同期 のみを設定し、データ移行がソースデータベースのローカル増分ログを48時間以上保存することを要求している場合。
データ移行タスクを新規作成する際に、完全な移行 + 増分同期 を設定し、データ移行がソースデータベースのローカル増分ログを少なくとも7日間以上保持することを要求している場合。そうでない場合、増分ログを取得できないためデータ移行タスクが失敗し、ソース側とターゲット側のデータが一致しなくなる可能性があります。
サポートされているソースおよびターゲットインスタンスタイプ
次の表では、OceanBase MySQL CompatibleおよびOceanBase Oracle Compatibleがサポートするインスタンスタイプには、クラスタインスタンス(トランザクション型) と 自己構築データベース が含まれます。
クラウドプロバイダー |
ソース |
ターゲット |
|---|---|---|
| AWS | OceanBase MySQL Compatible | クラウドインスタンスKafka |
| AWS | OceanBase MySQL Compatible | オンプレミスKafka |
| AWS | OceanBase Oracle Compatible | クラウドインスタンスKafka |
| AWS | OceanBase Oracle Compatible | オンプレミスKafka |
| ハイアワンクラウド | OceanBase MySQL Compatible | クラウドインスタンスKafka |
| ハイアワンクラウド | OceanBase MySQL Compatible | オンプレミスKafka |
| ハイアワンクラウド | OceanBase Oracle Compatible | クラウドインスタンスKafka |
| ハイアワンクラウド | OceanBase Oracle Compatible | オンプレミスKafka |
| テンセントクラウド | OceanBase MySQL Compatible | クラウドインスタンスKafka |
| テンセントクラウド | OceanBase MySQL Compatible | オンプレミスKafka |
| テンセントクラウド | OceanBase Oracle Compatible | クラウドインスタンスKafka |
| テンセントクラウド | OceanBase Oracle Compatible | オンプレミスKafka |
| アリババクラウド | OceanBase MySQL Compatible | クラウドインスタンスKafka |
| アリババクラウド | OceanBase MySQL Compatible | オンプレミスKafka |
| アリババクラウド | OceanBase Oracle Compatible | クラウドインスタンスKafka |
| アリババクラウド | OceanBase Oracle Compatible | オンプレミスKafka |
手順
データ移行タスクを新規作成します。

OceanBase Cloudコンソールにログインします。
左側のナビゲーションバーで、データサービス > データ移行 をクリックします。
データ移行 ページで、データ移行 タブをクリックします。
データ移行 タブで、右上の 移行タスクの新規作成 をクリックします。
ソースとターゲットの設定 ページで、各パラメータを設定します。
タスク名編集テキストボックスに、カスタムの移行タスク名を入力します。
数字と英字の組み合わせを使用することを推奨します。名前にはスペースを含めず、長さは64文字を超えないようにしてください。
ソース側 エリアで、各パラメータを設定します。
既に作成・保存されたデータソースを参照する必要がある場合、ソース側 の右側にある データソースの参照 をクリックし、ドロップダウンリストから対象データソースを選択します。選択完了後、ソースエリアの各設定が自動的に入力されます。現在の設定を新しいデータソースとして保存する場合、ソース側 エリアの右上にある 保存 アイコンをクリックしてください。
データソースの参照 のドロップダウンリストで データソース管理 をクリックすると、データソース ページに移動し、データソースの表示や管理ができます。このページでは異なる種類のデータソースを一元管理します。詳細については、データソース モジュールのドキュメントを参照してください。
パラメータ説明クラウドプロバイダー 現在、AWS、ファーウェイクラウド、Alibaba Cloud、および Tencent Cloud をサポートしています。 データベースタイプ ソースを OceanBase MySQL Compatible または OceanBase Oracle Compatible に設定します。 インスタンスタイプ 現在、クラスタインスタンス(トランザクション型) と 自己構築データベース をサポートしています。 リージョン ソースデータベースのリージョンを選択します。 インスタンス OceanBaseデータベースが配置されているインスタンスのIDまたは名前です。クラスタ ページで、ターゲットインスタンスのIDまたは名前を確認できます。 説明
クラウドプロバイダーがAlibaba Cloudの場合、アカウント間認証をサポートするAlibaba Cloudのメインアカウントインスタンスも選択できます。詳細については、Alibaba Cloudアカウント認証を参照してください。
テナント OceanBaseデータベースのテナントIDまたは名前です。インスタンス ページで、ターゲットインスタンスを展開し、そのインスタンス内のターゲットテナントのIDまたは名前を確認できます。 データベースアカウント データ移行用のOceanBaseデータベースのユーザー名。 パスワード データベースユーザーのパスワード。 ソースが オンプレミスデータベース インスタンスタイプの場合、構造移行と増分同期を行うには、詳細設定 エリアで各パラメータを設定してください。

タイプとオブジェクトの選択 ページで スキーマ移行 または 増分同期 を選択する必要がある場合は、sysテナントアカウントを有効にし、以下のパラメータを設定してください。
パラメータ説明sysアカウント sysユーザーの名前です。このユーザーは主にOceanBaseデータベースの増分ログとデータベースオブジェクト構造情報を読み取るために使用されます。業務クラスタのsysテナント内に作成してください。 パスワード sysユーザーのパスワード。 タイプとオブジェクトの選択 ページで 増分同期 を選択する必要がある場合は、増分ログプロキシサービスを有効にし、OBLogProxy 接続情報 を入力してください。
注意
sysテナントアカウントと増分ログプロキシサービスの両方を有効にする必要があります。これにより、増分同期がサポートされます。
OBLogProxy 接続情報 は、OceanBaseデータベースの増分ログプロキシサービスであり、サービス形態でリアルタイムの増分プロジェクトの介入と管理機能を提供し、アプリケーションがOceanBaseデータベースの増分ログに介入するのを容易にします。同時に、ネットワークが分離されている状況でも、増分ログのサブスクリプションニーズを解決できます。形式は
OBLogProxy IP:OBLogProxy Portです。
ターゲット側 エリアで、各パラメータを設定します。
既に作成・保存されたデータソースを参照する必要がある場合、ターゲット側 の右側にある データソースの参照 をクリックし、ドロップダウンリストから対象データソースを選択します。選択完了後、ターゲットエリアの各設定が自動的に入力されます。現在の設定を新しいデータソースとして保存する場合、ターゲット側 エリアの右上にある 保存 アイコンをクリックしてください。
データソースの参照 のドロップダウンリストで データソース管理 をクリックすると、データソース ページに移動し、データソースの表示や管理ができます。このページでは異なる種類のデータソースを一元管理します。詳細については、データソース モジュールのドキュメントを参照してください。
パラメータ説明クラウドプロバイダー 現在、AWS、ファーウェイクラウド、Alibaba Cloud、および Tencent Cloud をサポートしています。ソースと同じクラウドプロバイダーを選択することも、異なるクラウド間でのデータ移行も可能です。 説明
現在、クロスクラウドデータ移行機能はデフォルトで無効です。この機能を使用する場合は、OB Cloudテクニカルサポートにお問い合わせください。
データベースタイプ ターゲットを Kafka に設定します。 インスタンスタイプ クラウド インスタンス Kafka と 自己構築 Kafka をサポートしています。 リージョン ターゲットインスタンスのリージョンを選択します。 接続タイプ エンドポイント と パブリックネットワーク接続 が含まれます。 - エンドポイント を選択した場合、ページに表示されているアカウントIDをエンドポイントサービスのホワイトリストに追加し、そのアカウントのエンドポイントがエンドポイントサービスに接続できるようにする必要があります。詳細については、プライベートネットワーク接続の選択 のドキュメントを参照してください。
クラウドベンダー を AWS に設定した場合、エンドポイントサービス作成時にパラメータ エンドポイントを使用するために受け入れる必要がある で 有効にする を選択した場合、データ移行サービスが初めてプライベート接続にアクセスする際、AWSコンソールにアクセスし、受信した接続要求に対して エンドポイント接続要求を受け入れる 操作を行うよう求められます。 - パブリックネットワーク接続 を選択した場合、ページに表示されているデータソースIPアドレスをKafkaインスタンスのホワイトリストに追加し、接続性を確保する必要があります。詳細については、パブリックネットワーク接続の選択 のドキュメントを参照してください。
説明
ソースとターゲットのリージョンを選択すると、ページにホワイトリストに追加する必要があるデータソースIPアドレスが表示されます。
接続情報 - 接続タイプ を エンドポイント に設定した場合、エンドポイントサービス名とKafkaアクセスポイントを入力してください。
- 接続タイプ を パブリックネットワーク接続 に設定した場合、Kafkaアクセスポイントを入力してください。
Kafkaデータソースのセキュリティ認証設定が完了していない場合、そのデータソースをソースまたはターゲットとするデータ移行タスクは接続に失敗する可能性があります。セキュリティ認証エリアの設定は以下のとおりです。
ファイルをアップロードする をクリックし、拡張子が
.jksの信用証書をアップロードします。業務要件に応じて、SASL を有効にするかどうかを選択します。SASLを有効にする場合は、以下のパラメータを設定してください。
パラメータ説明認証方式 PLAIN、SCRAM-SHA-256、および SCRAM-SHA-512 をサポートします。 - PLAIN認証方式は比較的シンプルですが、ユーザーを動的に変更できず、ユーザー名とパスワードを平文で設定するため、セキュリティは高くありません。
- SCRAM(Salted Challenge Response Authentication Mechanism)認証方式は、ユーザー名とパスワードによる従来の認証メカニズムを実行することで、セキュリティ上の問題を解決します。KafkaはSCRAM-SHA-256をサポートしており、TLSと組み合わせてセキュリティ認証を実行できます。
この認証方式ではユーザーを動的に変更でき、ユーザーデータはZookeeperに保存されます。Brokerを起動する前に、まずZookeeperと通信し、Brokerとの通信用ユーザーを作成する必要があります。ただし、この認証方式ではユーザー名とパスワードを平文で設定する必要があります。 - KafkaはSCRAM-SHA-512をサポートしており、TLSと組み合わせてセキュリティ認証を実行できます。
ユーザー名 データ移行に使用するユーザー名。 パスワード データ移行に使用するユーザーのパスワード。
- エンドポイント を選択した場合、ページに表示されているアカウントIDをエンドポイントサービスのホワイトリストに追加し、そのアカウントのエンドポイントがエンドポイントサービスに接続できるようにする必要があります。詳細については、プライベートネットワーク接続の選択 のドキュメントを参照してください。
接続テストをして、次へ移動 をクリックします。
タイプとオブジェクトの選択 ページで、各パラメータを設定します。
移行タイプ エリアで、現在のデータ移行タスクの移行タイプを選択します。
パラメータ説明フル移行 フル移行タスク開始後、データ移行サービスは、ソースデータベースのテーブルにある既存データをターゲットデータベースの対応するテーブルに移行します。 増分同期 増分同期タスク開始後、データ移行は、ソースデータベースで変更されたデータ(追加、変更、削除)をターゲットデータベースの対応するテーブルに同期します。増分同期 には DML同期 と DDL同期期間 が含まれ、ニーズに応じてカスタマイズ設定できます。詳細については、DML/DDLのカスタム設定を参照してください。 移行オブジェクトの選択 エリアで、移行対象の選択方法を設定します。
オブジェクトの指定 と マッチングルール の2つの方法で移行対象を選択できます。
移行範囲の選択 エリアで、移行する対象を選択します。
オブジェクトの指定 を選択した場合、データ移行は データベース/テーブル移行 と データベース全体の移行 をサポートします。データベース・テーブル移行では、1つまたは複数のデータベース内のテーブルやビューを移行対象として選択できます。データベース全体の移行では、データベース全体を移行対象として選択できます。あるデータベースでデータベース・テーブル移行を選択した場合、そのデータベースではデータベース全体の移行はサポートされなくなります。あるデータベースでデータベース全体の移行を選択した場合、そのデータベースではデータベース・テーブル移行はサポートされなくなります。
OceanBaseデータベースのデータをKafkaに移行する場合、複数のテーブルから複数のTopicへの移行がサポートされます。
選択エリアの左側で、移行する対象を選択します。
> をクリックします。
オブジェクトをトピックにマッピング ダイアログの 既存のトピック ドロップダウンリストで、移行するTopicを検索して選択します。
確認 をクリックします。
データ移行はテキストによるオブジェクトのインポートをサポートし、ターゲット側のオブジェクトに対してTopicの変更、行フィルタの設定、単一またはすべてのオブジェクトの削除などの操作をサポートします。
説明
データベース全体の移行 を選択した場合:
右側のリストにはデータベース名のみが表示され、具体的なオブジェクトは表示されません。
増分同期-DDL同期 移行タイプを選択した場合、ソース側に新規追加されたテーブルはターゲット側に同期されます。
操作説明インポートオブジェクト 選択エリアの右側のリストで、右上の オブジェクトのインポート をクリックします。インポート移行オブジェクトを参照してください。 トピックの変更 データ移行では、ターゲットオブジェクトのトピックを変更する操作をサポートしています。トピックの変更を参照してください。 設定 データ移行は WHERE条件による行フィルタリング、およびシャーディング列と同期が必要な列の選択をサポートしています。設定 ダイアログボックスで、以下の操作を実行できます。- 行フィルタ条件 エリアのテキストボックスに
WHERE条件を入力して行フィルタリングを実行します。SQL条件でデータをフィルタリングするを参照してください。 - シャード列 のドロップダウンリストから、ターゲットのシャーディング列を選択します。複数のフィールドをシャーディング列として選択できます。このパラメータはオプションです。
シャーディング列を選択する際、特別な状況がない限り、主キーを選択するのがデフォルトです。主キーに負荷の不均衡がある場合は、一意の識別子で負荷が比較的均等なフィールドをシャーディング列として選択し、潜在的なパフォーマンス問題を回避してください。シャーディング列の主な役割は以下のとおりです:- 負荷分散:ターゲット側で同時書き込みが可能な場合、シャーディング列によってメッセージ送信に使用する特定のスレッドを区別します。
- 順序性:同時書き込みによって生じる可能性のある無秩序な問題に対処するため、データ移行はシャーディング列の値が同じ場合、ユーザーが受信するメッセージが順序付けられていることを保証します。ここでの順序とは、変更の順序(一列に対するDMLの実行順序)を指します。
- 列の選択エリアで、同期が必要な列を選択します。列のフィルタリングを参照してください。
全て削除/クリア データ移行では、データマッピング時に、一時的にターゲット側に選択された単一または複数のオブジェクトを削除する操作をサポートしています。 - 単一の移行オブジェクトの削除
選択エリアの右側のリストで、ターゲットオブジェクトの後ろにある 削除 アイコンをクリックすると、その移行オブジェクトを削除できます。 - すべての移行オブジェクトの削除
選択エリアの右側のリストで、右上の すべてクリア をクリックします。ダイアログボックスで、確認 をクリックすると、すべての移行オブジェクトを削除できます。
マッチングルール を選択した場合、詳細については データベースからメッセージキューへのマッチングルールの設定を参照してください。
次へ をクリックします。移行オプション ページで、各パラメータを設定します。
フル移行
タイプとオブジェクトの選択 ステップで、完全な移行 を選択した場合にのみ、以下のパラメータが表示されます。
パラメータ説明読み取り並列数設定 このパラメータは、フル移行段階でソース側からデータを読み取る並列数を設定します。最大値は512です。並列数が高すぎると、ソース側の負荷が過大になり、業務に影響を与える可能性があります。 書き込み並列数設定 このパラメータは、フル移行段階でターゲット側にデータを書き込む並列数を設定します。最大値は512です。並列数が高すぎると、ターゲット側の負荷が過大になり、業務に影響を与える可能性があります。 フル移行レートの制限 実際のニーズに応じて、フル移行レートの制限を有効にするかどうかを決定できます。有効にする場合は、RPS(フル移行段階で1秒間にターゲット側に移行できるデータ行数の最大値の制限)とBPS(フル移行段階で1秒間にターゲット側に移行できるデータ量の最大値の制限)を設定してください。 説明
ここで設定されたRPSとBPSは、スロットリング機能としてのみ機能します。フル移行で実際に達成可能な性能は、ソース側、ターゲット側、インスタンス仕様の設定などの要因の影響を受けます。
増分同期
タイプとオブジェクトの選択 ステップで、増分同期 を選択した場合にのみ、以下のパラメータが表示されます。
パラメータ説明書き込み並列数設定 このパラメータは、増分同期フェーズにおいてターゲット側にデータを書き込む並列数を設定します。最大制限は512です。並列数が高すぎると、ターゲット側の負荷が過大になり、業務に影響を与える可能性があります。 増分移行レートの制限 実際のニーズに応じて、増分同期レートの制限を有効にするかどうかを決定できます。有効にする場合は、RPS(増分同期フェーズにおいて1秒間にターゲット側に同期できるデータ行数の最大値の制限)とBPS(増分同期フェーズにおいて1秒間にターゲット側に同期できるデータ量の最大値の制限)を設定してください。 説明
ここで設定されたRPSとBPSは、スロットリング機能としてのみ機能します。増分同期が実際に達成できる性能は、ソース側、ターゲット側、インスタンス仕様の設定などの要因の影響を受けます。
増分同期開始時刻 - 移行タイプとして 完全な移行 を選択した場合、このパラメータは表示されません。
- 移行タイプとして 完全な移行 を選択せず、増分同期 を選択した場合は、この時間以降のデータを移行するように指定してください。デフォルトは現在のシステム時刻です。詳細については、増分同期の開始時刻の設定を参照してください。
詳細オプション
パラメータ説明シリアライズ方式 Kafkaへのデータ移行時のメッセージ形式を制御します。現在、Default、Canal、DataWorks(V2.0以降)、SharePlex、DefaultExtendColumnType、Debezium、DebeziumFlatten、DebeziumSmt、Avroをサポートしています。詳細については、データ形式の説明を参照してください。 説明
- 現在、Debezium、DebeziumFlatten、DebeziumSmt、AvroはOceanBaseデータベースのMySQL互換モードでのみサポートされています。
- DataWorksを選択した場合、DDL同期は
COMMENT ON TABLEおよびALTER TABLE…TRUNCATE PARTITIONをサポートしません。
パーティションルール OceanBaseデータベースのデータをKafkaトピックに同期するルールです。現在、Hash、Table、Oneをサポートしています。異なるシナリオでのDDLステートメントの配信と例については、表の下部の説明を参照してください。 - Hashは、データ移行が特定のHashアルゴリズムを使用し、主キー値またはシャーディング列値のHashに基づいてKafkaトピックのパーティションを選択することを示します。 Tableは、データ移行がテーブル内のすべてのデータを同一のパーティションに配信し、テーブル名をHashキーとして使用することを示します。Oneは、JSONメッセージがトピック内の特定のパーティションに配信されることを示し、ソートを維持することを目的としています。
業務システム識別子(オプション) **シリアル化方式**をDataWorksとしてのみ選択した場合、このパラメータが表示されます。データの業務システム出所を識別し、後続のカスタム処理を容易にするために使用されます。この業務システム識別子の長さは1文字から20文字までと制限されています。 以下の表は、異なるシナリオにおけるDDLステートメントの配信方法を示しています。
パーティショニングルールDDLステートメントが複数のテーブルに関連する場合(例:RENAME TABLE)DDLステートメントで関連テーブルが特定できない場合(例:DROP INDEX)DDLステートメントが単一のテーブルに関連する場合Hash DDLステートメントは、関連テーブルが存在するトピックのすべてのパーティションに配信されます。
例えば、DDLステートメントがA、B、Cの3つのテーブルに関連している場合、AがTopic 1に、BがTopic 2に、Cがこのタスクに含まれていない場合、そのDDLステートメントはTopic 1とTopic 2のすべてのパーティションに配信されます。DDLステートメントは、このタスクのすべてのトピックのすべてのパーティションに配信されます。
例えば、DDLステートメントがデータ移行によって認識されない場合、このタスクに3つのトピックが存在すると、そのDDLステートメントはこれら3つのトピックのすべてのパーティションに配信されます。DDLステートメントは、そのテーブルが属するトピックのすべてのパーティションに配信されます。 Table DDLステートメントは、関連テーブルが存在するトピックの、対応するテーブル名のHash値が存在するパーティションに配信されます。
例えば、DDLステートメントがA、B、Cの3つのテーブルに関連している場合、AがTopic 1に、BがTopic 2に、Cがこのタスクに含まれていない場合、そのDDLステートメントはTopic 1とTopic 2の関連テーブルのHash値が存在するパーティションに配信されます。DDLステートメントは、このタスクのすべてのトピックのすべてのパーティションに配信されます。
例えば、DDLステートメントがデータ移行によって認識されない場合、このタスクに3つのトピックが存在すると、そのDDLステートメントはこれら3つのトピックのすべてのパーティションに配信されます。Table Nameに基づいてHashを計算し、そのテーブルが属するトピック内の特定のパーティションに配信されます。 One DDLステートメントは、関連テーブルが存在するトピックの固定パーティションに配信されます。
例えば、DDLステートメントがA、B、Cの3つのテーブルに関連している場合、AがTopic 1に、BがTopic 2に、Cがこのタスクに含まれていない場合、そのDDLステートメントはTopic 1とTopic 2の特定の固定パーティションに配信されます。DDLステートメントは、このタスクのすべてのトピックの特定の固定パーティションに配信されます。
例えば、DDLステートメントがデータ移行によって認識されない場合、このタスクに3つのトピックが存在すると、そのDDLステートメントはこれら3つのトピックの特定の固定パーティションに配信されます。DDLステートメントは、そのテーブルが属するトピックの特定の固定パーティションに配信されます。
次へ をクリックすると、システムがデータ移行タスクの事前チェックを実行します。
事前チェック プロセスでは、データ移行はターゲット側のKafkaとの接続状況を検出します。事前チェックでエラーが発生した場合:
問題を調査・解決した後、事前チェックが成功するまで再度実行できます。
失敗した事前チェック項目の操作列にある スキップ をクリックすると、この操作の具体的な影響を示すダイアログがポップアップ表示されます。スキップしてもよいことを確認したら、ダイアログの 確認 をクリックしてください。
事前チェックが成功したら、購入 をクリックし、データ移行インスタンスの購入 ページで購入します。
購入が成功すると、データ移行タスクを開始できます。購入の詳細については、データ移行インスタンスの購入を参照してください。データ移行インスタンスの購入は、現時点では不要な場合は、保存 をクリックしてデータ移行タスクの詳細ページに移動し、後から手動で購入することもできます。
データ移行サービスは、データ移行タスクの実行中に移行対象を変更することをサポートしています。詳細については、移行対象の表示と変更を参照してください。データ移行タスクは開始後、選択した移行タイプに従って順次実行されます。詳細については、データ移行タスクの詳細を見るの「移行詳細を見る」モジュールの内容を参照してください。