RocketMQSink

启动类

rocketmq_sink-sink.jar

com.oceanbase.oms.connector.rocketmq.sink.RocketMQSinkBooster

【元信息】nameSvrAddr

• 功能：RocketMQ 的地址

• 默认值：无，必填

• 值的选择范围：string

• 支持的版本：OMS 社区版 3.3.1-CE 及之后版本

【鉴权】accessKey

• 功能：RocketMQ 的 AccessKey ID

• 默认值：无

• 值的选择范围：string

• 支持的版本：OMS 社区版 3.3.1-CE 及之后版本

【鉴权】secretKey

• 功能：RocketMQ 的 AccessKey Secret

• 默认值：无

• 值的选择范围：string

• 支持的版本：OMS 社区版 3.3.1-CE 及之后版本

【元信息】producerGroup

• 功能：RocketMQ 的 Producer Group

• 默认值：OMS

• 值的选择范围：string

• 支持的版本：OMS 社区版 3.3.1-CE 及之后版本

【message 设置】tags

• 功能：message tags，如果填写会在后面加上 "_tag" 后缀

• 默认值：default

• 值的选择范围：string

• 支持的版本：OMS 社区版 3.3.1-CE 及之后版本

【分发】partitionMode

• 功能：分发逻辑，确定哪条数据写入哪个分区

• 默认值：HASH

• 值的选择范围：HASH（主键 Hash 确定）/ TABLE（按照 Table 名称 Hash）

• 支持的版本：OMS 社区版 3.3.1-CE 及之后版本

【线程】workerNum

• 功能：写入线程数

• 默认值：4

• 值的选择范围：int

• 支持的版本：OMS 社区版 3.3.1-CE 及之后版本

【错误处理】sendMsgTimeout

• 功能：写消息超时

• 默认值：3000ms

• 值的选择范围：int

• 支持的版本：OMS 社区版 3.3.1-CE 及之后版本

【RocketMQ 配置项】enableTrace

• 功能：是否开启 rocket client trace

• 默认值：false

• 值的选择范围：boolean

• 支持的版本：OMS 社区版 3.3.1-CE 及之后版本

【序列化】serializerType

• 功能：序列化格式

• 默认值：DEFAULT

• 值的选择范围：DEFAULT/DEFAULT_WITH_SCHEMA/SHAREPLEX/CANAL/DATAWORKS_V2/DATAWORKS_V1

• 支持的版本：OMS 社区版 3.3.1-CE 及之后版本