StoreSource

启动类

connector-source-store.jar

com.oceanbase.oms.connector.source.store.MultiStoreSourceBooster

【元信息】clients

• 功能：连接 Store 的必要信息

• 默认值：无，必填

• 值的选择范围：

  {
  "clientId": "唯一标识，也是 Condition 填写的 source_id，用于确定该 Client 产生的心跳传递。推荐使用 Subtopic",
  "subtopic": "store subtopic",
  "clusterManagerUrl": "store url/cm url",
  "filterConditions": "store 白名单" // 该配置项仅逻辑表生效。物理表依赖 Conditions 配置项，该配置项不生效。
  }
  

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

【元信息】username

• 功能：连接 Store 需要的账号（如果是经过 CM）

• 默认值：无

• 值的选择范围：string

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

【元信息】password

• 功能：连接 Store 需要的账号密码（如果是经过 CM）

• 默认值：无

• 值的选择范围：string

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

【元信息】dbType

• 功能：Store 背后数据库的类型

• 默认值：无，必填

• 值的选择范围：MYSQL/OB_MYSQL/OB_ORACLE/ORACLE/DB2_LUW/POSTGRESQL/... DbTypeEnum

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

• 备注：中间层存在 sourceType 信息，如果缺少 dbType 参数中间层的 sourceType 会充当 dbType 使用，默认是以 source.json 的 dbType 为准

【位点信息】checkpoint

• 功能：Store 启动位点信息

• 默认值：无，必填

• 值的选择范围：json

  {
  "clientId 作为 key": "timestamp 作为值" // 此处的 clientId 为 clients 配置的 clientId。
  }
  

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

【Store 相关参数】connectionTimeoutSec

• 功能：store 连接超时时间

• 默认值：120

• 值的选择范围：int

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

【Store 相关参数】maxRetries

• 功能：拉取 Store 数据重试次数

• 默认值：1000

• 值的选择范围：int

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

【防循环复制】askSelfUnit

• 功能：是否仅请求由 drc 产生的数据

• 默认值：false

• 值的选择范围：boolean

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

【防循环复制】blackRegionNo

• 功能：不需要的 regionNo，用于防循环复制

• 默认值：空，表示不过滤

• 值的选择范围：int

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

【防循环复制】drcMarkTable

• 功能：事务表方案，防循环复制使用的表

• 默认值：空

• 值的选择范围：string

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

【防循环复制】drcMarkDb

• 功能：事务表方案，防循环复制使用的表所在的库

• 默认值：空

• 值的选择范围：string

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

【DDL】ignoreDdl

• 功能：是否忽略 DDL

• 默认值：true

• 值的选择范围：true 或 false

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

【事务拆分】splitThreshold

• 功能：大事务拆分参数

• 默认值：128

• 值的选择范围：int

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

【Store 相关参数】storeProperties

• 功能：透传 Store Client 参数

• 默认值：无

• 值的选择范围：json kv

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

【Store 相关参数】sourceBatchMemorySize

• 功能：限制一个事务内最大 recordBatch 大小，根据 JVM 内存设置。recordBatch 和 splitThreshold 仅一个达到便会拆分事务同步

• 默认值：默认值为 4194304，单位为 bytes

• 值的选择范围：int

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