在配置迁移到Kafka的数据迁移任务时,为提升迁移的性能,您可以调整Kafka Partition(分区)迁移策略,例如根据Hash结果将数据迁移至不同的Partition。
Hash算法
DTS采用Java默认的hashcode算法来计算Hash值。
配置方法
您需要在配置数据迁移任务的迁移类型及列表环节中配置Kafka Partition迁移策略。配置案例请参见从自建Oracle迁移至阿里云消息队列Kafka,更多相关案例请参见迁移方案概览。
警告 数据迁移任务启动后,请勿修改目标Topic的Partition数量,否则将导致数据迁移失败。
策略说明
策略名称 | 说明 | 优缺点 |
---|---|---|
全部递到Partition 0 | 将所有数据和DDL信息都投递到目标Topic的Partition 0。 |
|
按库名+表名的hash值投递到不同Partition | 将库名与表名合并作为Partition Key来计算Hash值,然后将各个表的数据和DDL信息投递到目标Topic中的各个Partition。 说明
|
|
按主键的hash值投递到不同Partition | 将表中的列(默认为主键,如果无主键则使用唯一键)作为Partition Key来计算Hash值,然后将不同的行投递到目标Topic的各个Partition中。您也可以指定单个或多个列作为Partition Key来计算Hash值。 说明
|
|