データ移行タスクに Kafka パーティションポリシーを指定して、パフォーマンスを向上させることができます。たとえば、ハッシュ値に基づいてデータを複数のパーティションに分散させることができます。
ハッシュアルゴリズム
Data Transmission Service (DTS) は、Java の hashCode() メソッドを使用してハッシュ値を計算します。
設定方法
タスク作成ウィザードの [移行タイプとオブジェクトの設定] ステップで Kafka パーティションポリシーを指定します。詳細については、「セルフマネージドOracleからMessage Queue for Apache Kafkaへの移行」および「移行シナリオ」をご参照ください。
警告 データ移行タスクの開始後に、送信先トピックのパーティション数を変更しないでください。変更すると、データ移行が失敗します。
ポリシー
| ポリシー | 説明 | メリット・デメリット |
| [すべてのデータをパーティション 0 へ転送] | すべてのデータと DDL ステートメントを、送信先トピックのパーティション 0 に移行します。 |
|
| [データベース名とテーブル名のハッシュ値に基づいてデータを個別のパーティションに転送] | データベース名とテーブル名をパーティションキーとして使用してハッシュ値を計算し、各テーブルのデータと DDL ステートメントを送信先トピックの対応するパーティションに移行します。 説明
|
|
| [プライマリキーのハッシュ値に基づいてデータを個別のパーティションに転送] | テーブルの列をパーティションキーとして使用してハッシュ値を計算します。デフォルトでは、プライマリキーが使用されます。テーブルにプライマリキーがない場合は、代わりに一意キーが使用されます。各行は、送信先トピックの対応するパーティションに移行されます。1 つ以上の列をパーティションキーとして指定することもできます。 説明
|
|