---
title: "RocketMQSink | OceanBase 文档中心"
description: RocketMQSink 启动类 rocketmq_sink-sink.jar com.oceanbase.oms.connector.rocketmq.sink.RocketMQSinkBooster 【元信息】nameSvrAddr 功能：RocketMQ 的地址 默认值：无，必填 值的选择范围：string 支…
---
切换语言

- 中文站 - 简体中文
- International - English
- 日本站 - 日本語

文档反馈![](https://mdn.alipayobjects.com/huamei_22khvb/afts/img/A*L03BS6f-o40AAAAAAAAAAAAADiGDAQ/original) 迁移服务 OMSV 4.2.8 社区版

# RocketMQSink

更新时间：2026-04-14 15:40:47

[编辑](https://github.com/oceanbase/oms-doc/edit/V4.2.8/zh-CN/900.o-m-manual/400.components/500.component-parameters/400.sink-plugin/500.rocketmq-sink.md)  

## 启动类

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

 上一篇 下一篇 ![有帮助](https://gw.alipayobjects.com/mdn/ob_asset/afts/img/A*y6ocSqN8cqsAAAAAAAAAAAAAARQnAQ)![无帮助](https://gw.alipayobjects.com/mdn/ob_asset/afts/img/A*BG9IQJyLHF8AAAAAAAAAAAAAARQnAQ)![反馈](https://gw.alipayobjects.com/mdn/ob_asset/afts/img/A*eTWdQKCRKHwAAAAAAAAAAAAAARQnAQ)[AI](https://www.oceanbase.com/obi) 咨询热线