AutoMQ 到 Oracle

CloudCanal 支持从 AutoMQ 到 Oracle 的数据迁移、同步、校验和链路能力。

选择对端数据库：

Oracle

数据链路

基本功能

功能	说明
增量实时同步	支持订阅源端 Topic 的消息，并转换为 INSERT、UPDATE、DELETE DML
修改订阅	新增、删除、修改订阅 Topic，文档：修改订阅
重置位点	按 时间戳 回溯位点，重新消费过去一段时间的数据

高级功能

功能	说明
消息格式	支持以下消息格式，文档：消息格式说明 CloudCanal内置格式 AlibabaCanal兼容格式
全量前清空目标数据	运行全量任务前清除老数据，包括重跑任务、定时全量迁移都会触发此能力
重建目标表	运行全量任务前重建目标表，包括重跑任务、定时全量迁移都会触发此能力
增量写入冲突策略	IGNORE: 主键冲突则忽略（不做写入），REPLACE: 主键冲突则整行替换
0 值时间处理	支持将 0 值时间设置成不同类型的值，防止写入对端报错

限制和注意点

限制项	说明
目标端需要提前创建表	仅支持消息自动创建 Topic
原始消息格式	仅支持 AutoMQ 到 AutoMQ，且两端的消息格式都需要选择 原始消息格式

使用示例

标题	详情
CloudCanal x AutoMQ 数据迁移同步	文档：CloudCanal x AutoMQ 数据迁移同步
跨互联网数据互通 (AutoMQ)	文档：跨互联网数据互通 (AutoMQ)
AutoMQ 数据中转校验	文档：AutoMQ 数据中转校验

链路FAQ

• 如何打开 AutoMQ 源端心跳?

---

源端数据源

前置条件

条件	说明
网络准备	迁移同步节点（sidecar）可连接 AutoMQ 各节点

任务参数

参数名称	说明
schemaFormat	MQ 消息格式，文档：消息格式说明
consumerGroupId	AutoMQ 消费组 Id
consumeParallel	消费 AutoMQ 的并行度
sessonTimeoutMs	AutoMQ Session 超时时间（毫秒）
maxPollRecords	AutoMQ 一次最大拉取消息数量

Tips: 通用参数配置请参考 通用参数及功能

---

目标端数据源

前置条件

条件	说明
账号权限	文档：Oracle 需要的权限
网络准备	迁移同步节点（sidecar）可连接 ORACLE 标准交互接口（如 1521）

任务参数

参数名称	说明
keyConflictStrategy	增量写入遇到主键冲突策略: IGNORE 冲突忽略（默认） REPLACE 冲突替换（可选）
dstWholeReplace	将 INSERT 和 UPDATE 操作变成对端整行覆盖
writeStrategy	对端写入策略，包含 ROW (单条) MULTI_SQL (多语句) BATCH (批量，默认选项)

Tips: 通用参数配置请参考 通用参数及功能