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 及之后版本

【时区转换】dateTimezone

• 功能：设置 dateTime 所在的时区

  例如，配置为 +08:00，表示 dateTime 是 +8 时区的时间。

• 默认值：0

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

【时区转换】dateConvertTimezone

• 功能：设置时间转换后的时区

  例如，配置为 +08:00，表示将时间转换为 +8 时区的时间

• 默认值：0

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

【时区转换】dateConvertFormat

• 功能：时间格式化配置

  例如，yyyy-MM-dd HH:mm:ss，配置后 datetime 和 timestamp 会转换为根据指定格式输出时间。

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