RocketMQ
选择对端数据库：
RocketMQ
| 功能 | 说明 |
|---|---|
增量实时同步 | 支持订阅源端 Topic 的消息 |
修改订阅 | 新增、删除、修改订阅 Topic，文档：修改订阅 |
重置位点 | 按 时间戳 回溯位点，重新消费过去一段时间的数据 |
高级功能
| 功能 | 说明 |
|---|---|
Message Format | The following message formats are supported. See Message Format.
|
限制和注意点
| 限制项 | 说明 |
|---|---|
Creating Tables in the Target in Advance | Only support automatic Topic creation for messages. |
Raw Message Format | Only support raw message replication from RocketMQ to RocketMQ, and Raw Message Format needs to be selected at both the Source and the Target. |
前置条件
| 条件 | 说明 |
|---|---|
Port Preparation | Allow the migration and sync node (Worker) to connect to the RocketMQ nodes. |
任务参数
| 参数名称 | 说明 |
|---|---|
schemaFormat | MQ message format. For more information, see Message Format. |
Tips: 通用参数配置请参考 通用参数及功能