自建Apache RocketMQ事件源
更新时间 2025-12-29 16:49:23
最近更新时间: 2025-12-29 16:49:23
本文介绍如何在事件总线EventBridge管理控制台添加自建Apache RocketMQ作为事件流中的事件提供方。
前提条件
事件总线EventBridge
操作步骤
登录事件总线管理控制台。
在左侧导航栏，单击事件流。
在事件流页面，单击创建事件流。
在事件源（Source）配置面板，事件提供方选择自建Apache RocketMQ，选择或填入主题等配置然后单击确认。
参数说明
| 参数 | 说明 | 示例 |
|---|---|---|
| 名称 | 事件源名。 | source1 |
| 接入点 | Apache RocketMQ集群broker接入点，由IP与端口号拼接而成，以逗号分隔。 | 172.17.0.25:9876,192.17.0.26:9876,172.17.0.27:9876 |
| Topic | topic名称。 | topic1 |
| Group ID | 填入当前Apache Kafka集群中已创建的Group，请不要与已有业务的Group混用，以免影响已有的消息收发。 | group1 |
| Tag | 用于消息过滤的Tag，非必填。 | tag |
| 网络配置 | 根据业务场景选择对应配置。
| 专有网络 |
| VPC | 网络配置选择专有网络时必填，选择集群所在的VPC。 | vpc-**** |
| 子网 | 网络配置选择专有网络时必填，选择集群所在的子网。 | subnet-**** |
| 认证模式 | 选择认证模式。
| 无需配置 |
| 消费位点 | 消费消息的位点。
| 最早位点 |
| 数据格式 | 消息value数据编码格式。
| JSON |
事件示例
{
"id": "6867708c-5727-419c-8170-9c14922ae3a8",
"specversion": "1.0",
"source": "apache:rocketmq",
"type": "apacherocketmq:Topic:SendMessage",
"subject": "apache:rocketmq:bb9fdb42056xxxxxx0242ac110002:dab4124510dd4xxxxxxxxx5c6a6db69:topic:stream_source",
"datacontenttype": "application/json",
"time": "2025-10-30T07:25:03.447869811Z",
"data": {
"topic": "stream_source",
"msgId": "0A3D1A3A09D00000000098a355280003",
"userProperties": {},
"systemProperties": {
"CLUSTER": "DefaultCluster",
"CONSUME_START_TIME": "1761809103447",
"MAX_OFFSET": "8",
"MIN_OFFSET": "0",
"UNIQ_KEY": "0A3D1A3A09D00000000098a355280003"
},
"body": "Hello RocketMQ Go Client! This is a sync message 2"
},
"ctyunaccountid": "dab4124510dd4xxxxxxxxx5c6a6db69",
"ctyunregion": "bb9fdb42056xxxxxx0242ac110002"
}data字段包含的参数解释如下表所示：
| 参数 | 类型 | 示例值 | 描述 |
|---|---|---|---|
| topic | String | source1 | Topic名称。 |
| msgId | String | 210018FC0EE205EF04B51CF068350066 | 消息ID。 |
| systemProperties | Object | 详见systemProperties属性参数解释 | 消息systemProperties。 |
| userProperties | Object | {} | 消息properties。 |
| body | Object | WebsFjDDxPd503bG60bNdaT0qMrsjt5evXd9df | 消息体，默认以JSON格式编码。 |
data字段中systemProperties属性的参数解释如下图所示：
| 参数 | 类型 | 示例值 | 描述 |
|---|---|---|---|
| CLUSTER | String | 16e0eef12f83485dbba23a0750ec5078 | RocketMQ实例集群ID。 |
| CONSUME_START_TIME | String | 1733467917369 | 开始消费时间戳。 |
| KEYS | String | key | 消息Key值。 |
| TAGS | String | 1733467917351_0 | 消息Tag值。 |
| MIN_OFFSET | String | 0 | 最小消费位点。 |
| MAX_OFFSET | String | 1 | 最大消费位点。 |
