Coordinator（框架层）

Coordinator（框架层）的配置路径为 conf/coordinator.json。

【JVM】connectorJvmParam

• 功能：JVM 参数信息

• 默认值：无

• 值的选择范围：JVM 相关参数

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【攒批分发】maxRecordCapacity

• 功能：Dispatcher 队列大小

• 默认值：16384

• 值的选择范围：int

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【攒批分发】bridgeQueueSize

• 功能：中间队列长度

• 默认值：256

• 值的选择范围：int

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【攒批分发】shuffleMinBatchSize

• 功能：配合 ShuffleRecordDispatcher 使用，最小攒批限制

  ShuffleRecordDispatcher 是同步至消息队列（Kafka/RocketMQ/DataHub）的消息分发器，主要目的是提升消息的并发效率。

• 默认值：20

• 值的选择范围：int，取值需要小于 shuffleMaxBatchSize 的取值

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【攒批分发】shuffleMaxBatchSize

• 功能：配合 ShuffleRecordDispatcher 使用，最大攒批限制

• 默认值：64

• 值的选择范围：int

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【攒批分发】shuffleFlushIntervalMs

• 功能：配合 ShuffleRecordDispatcher 使用，攒批最长时间

• 默认值：100ms

• 值的选择范围：int

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【攒批分发】shuffleBucketMaxInFlightBatchSize

• 功能：配合 ShuffleRecordDispatcher 使用，同一个桶中允许没有 ACK 的消息数量

• 默认值：增量 = 1，全量 = -1 表示不限制

• 值的选择范围：int

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【攒批分发】shuffleBucketSize

• 功能：配合 ShuffleRecordDispatcher 使用。桶数量，表示可并发数量

• 默认值：无，必须填写

• 值的选择范围：int

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【事务写】useTxId

• 功能：是否使用事务 ID

• 默认值：false

• 值的选择范围：boolean

• 支持版本：OMS 社区版 V3.3.1-CE 及之后版本

【事务写】antiLoopMode

• 功能：是否使用事务表防事物回放模式

• 默认值：false

• 值的选择范围：true 或 false

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【无主键表】obHiddenPrimaryKeySyncDestColumn

• 功能：OceanBase 数据库隐藏列转化指定列名

• 默认值：OMS_PK_INCRMT

• 值的选择范围：String

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【无主键表】rowidExtendedColumns

• 功能：Oracle rowid 转化 4 列指定列名

• 默认值：OMS_OBJECT_NUMBER,OMS_RELATIVE_FNO,OMS_BLOCK_NUMBER,OMS_ROW_NUMBER

• 值的选择范围：String

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【无主键表】noPkOrUkAllowed

• 功能：总开关，是否支持没有 PK 或者 NOT NULL UK 的同步

• 默认值：true，实际根据源端和目标端的类型决定

• 值的选择范围：boolean

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【HTTP 接口】listenPort

• 功能：HTTP 开放端口

• 默认值：0，随机端口

• 值的选择范围：推荐 30000 以后，避免冲突

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【DDL】skipDdl

• 功能：跳过的 DDL

• 默认值：无

• 值的选择范围：JSON 数组

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【DDL】filterComment

• 功能：是否过滤 DDL 的 comment

• 默认值：false

• 值的选择范围：boolean

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【DDL】shuffleDdlToAllRoute

• 功能：采用 shuffleRecordDispatcher 时，如果遇到 DDL 是否同步到所有队列中

• 默认值：false

• 值的选择范围：booleann

• 支持的版本：OMS 社区版 V4.0.0-CE 及之后版本

【DDL】charsetMapping

• 功能：DDL charset 映射

• 默认值：空

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【DDL】collationMapping

• 功能：DDL collation 映射 map

• 默认值：空

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【错误处理】runIgnoreError

• 功能：遇到异常表同步失败不退出

• 默认值：false

• 值的选择范围：boolean

• 支持的版本：OMS 社区版 V4.0.0-CE 及之后版本

【过滤】allowRecordTypes

• 功能：链路级别过滤的消息类型

• 默认值：默认不过滤

• 值的选择范围：逗号分隔字符串，ROW/DELETE/UPDATE/INSERT/HEARTBEAT/REPLACE

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【特定场景】intervalTypeFmt

• 功能：interval 类型的格式

• 默认值：无，查询数据库获取

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【特定场景】timestamptzConvert

• 功能：是否转换 Asia/shanghai 时区到 +08:00

• 默认值：源端为 OceanBase 数据库 Oracle 租户或 Oracle 数据库时，默认值为 true，其余为 false

• 值的选择范围：boolean

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【大小写】caseStrategy

• 功能：大小写处理策略

• 默认值：默认值为 FOLLOW_SOURCE，即根据源端的大小写进行匹配

• 值的选择范围：DEFAULT/FOLLOW_SOURCE/UPPER/LOWER

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【大小写】isCaseSensitive

• 功能：是否大小写敏感

• 默认值：false

• 值的选择范围：boolean

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【热点合并】hotKeyMerge

• 功能：是否开启热点合并

• 默认值：false

• 值的选择范围：boolean

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【热点合并】hotKeyTable

• 功能：初始化配置热点表

• 默认值：无

• 值的选择范围：jsonArray

  例如，[{"schema":"db1","table":"table1"},{"schema":"db1","table":"table1"}]

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【热点合并】mergeDelayThreshold

• 功能：超过多少个 Key 堆积认为热点

• 默认值：120

• 值的选择范围：int

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【统计】enableDmlDdlTypeStatistics

• 功能：是否开启 DDL/DML 统计功能

• 默认值：false

• 值的选择范围：boolean

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【统计】reportIntervalSec

• 功能：输出 checkpoint/heartbeat/ diagnose 文件的间隔时间

• 默认值：5

• 值的选择范围：int

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【特殊场景】systemDefaultTimezone

• 功能：读取时间的时区

• 默认值：默认读系统时区

• 值的选择范围：时区

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【特定场景】db2Mode

• 功能：DB2 LUW 数据库的 mode 模式，包括 oracle 和 normal

• 默认值：normal

• 值的选择范围：oracle、normal

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【特定场景】mysqlVersion

• 功能：源端 MySQL 数据库的版本

• 默认值：查询获取

• 值的选择范围：MySQL 数据库的版本

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【限流】throttleRps

• 功能：限制 RPS

• 默认值：none，表示不限制

• 值的选择范围：int 和 "none"

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【限流】throttleIOPS

• 功能：限制流量，单位为字节

• 默认值：none，表示不限制

• 值的选择范围：int 和 "none"

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【限流】throttleRecordBound

• 功能：限制框架内 Record 的个数

• 默认值：none，表示不限制

• 值的选择范围：int 和 "none"

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【限流】throttleMemoryBound

• 功能：限制内存，单位为字节

• 默认值：none，表示不限制

• 值的选择范围：int 和 "none"

• 支持的版本：OMS 社区版 V3.3.1-CE 及之后版本

【预检查】【全量】checkDstTableEmpty

• 功能：是否检查表为空。

• 默认值：true

• 值选择范围：true 和 false

  OMS 会在项目第一次启动时（非恢复场景）检查目标端表是否为空。如果值为 true，目标端表为空则报错。如果值为 false，目标端表为空不报错。

• 支持版本：OMS 社区版 V4.0.0-CE 及之后版本

【HBase】mode

• 功能：HBase 数据库至 OBKV 的全量迁移或增量同步时的运行模式。

• 默认值：local

• 值选择范围：local 或 platform

  local 表示本地运行模式，platform 表示在计算平台中运行（目前仅支持 FLINK 计算平台）。

• 支持版本：OMS 社区版 V4.2.1-CE 及之后版本

【Hbase】platform

• 功能：HBase 数据库至 OBKV 的全量迁移或增量同步时，在计算平台运行的相关参数。仅设置 mode 为 platform 时生效。

• 默认值：无

• 值选择范围：{}

• 支持版本：OMS 社区版 V4.2.1-CE 及之后版本