データをKafkaクラスターに移行するタスクを設定する場合、データをKafkaパーティションに移行するためのポリシーを指定できます。 このポリシーにより、移行のパフォーマンスを向上させることができます。 たとえば、ハッシュ値に基づいてデータを異なるパーティションに移行できます。
ハッシュアルゴリズム
Data Transmission Service (DTS) は、JavaのhashCode() メソッドを使用してハッシュ値を計算します。
設定方法
タスク作成ウィザードの [移行タイプとオブジェクトの設定] ステップで、データをKafkaパーティションに移行するためのポリシーを指定できます。 詳細については、「自己管理型OracleデータベースからMessage Queue For Apache Kafkaインスタンスへのデータの移行」および「データ移行シナリオの概要」をご参照ください。
警告 データ移行タスクの開始後、移行先トピックのパーティション数を変更しないでください。 そうでない場合、データ移行は失敗します。
ポリシー
| ポリシー | 説明 | 利点と欠点 |
| Ship All Data to Partition 0 | DTSは、すべてのデータおよびDDLステートメントを移行先トピックのパーティション0に移行します。 |
|
| データベース名とテーブル名のハッシュ値に基づいてパーティションを分離するためのデータの出荷 | DTSは、データベースとテーブル名をパーティションキーとして使用して、ハッシュ値を計算します。 次に、DTSは、各テーブルのデータおよびDDLステートメントを、宛先トピックの対応するパーティションに移行します。 説明
|
|
| プライマリキーのハッシュ値に基づいてパーティションを分離するためのデータの出荷 | DTSは、テーブル列をパーティションキーとして使用してハッシュ値を計算します。 テーブル列はデフォルトで主キーです。 テーブルに主キーがない場合、一意のキーがパーティションキーとして使用されます。 DTSは、各行を宛先トピックの対応するパーティションに移行します。 1つ以上の列をパーティションキーとして指定して、ハッシュ値を計算できます。 説明
|
|