自定义自建Apache RocketMQ事件源
更新时间 2025-12-29 16:45:09
最近更新时间: 2025-12-29 16:45:09
本文介绍如何在事件总线EventBridge管理控制台中添加自建Apache RocketMQ类型的自定义事件源。
前提条件
事件总线EventBridge
您已部署Apache RocketMQ集群，并在您的天翼云VPC内或公共网络可访问集群接入点。
操作步骤
登录事件总线管理控制台。
在左侧导航栏，单击事件总线。
在事件总线页面，单击目标总线名称。
在左侧导航栏，单击事件源。
在事件源页面，单击添加事件源。
在添加自定义事件源面板，输入名称和描述，事件提供方选择自建Apache RocketMQ，配置相关参数，然后单击确认，如图1所示。
图1 创建事件源时事件提供方选择自建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 |
事件示例
{
"specversion": "1.0",
"id": "f64f466a-5d88-45bf-8edd-e0c9c34ba5c4",
"source": "source3",
"type": "apacherocketmq:Topic:SendMessage",
"subject": "apache:rocketmq:bb9fdb42056xxxxxx0242ac110002:dab4124510dd4xxxxxxxxx5c6a6db69:topic:topic1",
"datacontenttype": "application/json",
"time": "2025-10-30T03:53:30.833615567Z",
"data": {
"topic": "topic1",
"msgId": "0A3D1A3A97C40000000097e5a690001e",
"userProperties": {},
"systemProperties": {
"CLUSTER": "DefaultCluster",
"CONSUME_START_TIME": "1761796410833",
"MAX_OFFSET": "13",
"MIN_OFFSET": "0",
"UNIQ_KEY": "0A3D1A3A97C40000000097e5a690001e"
},
"body": "Hello RocketMQ Go Client! This is a sync message 29"
},
"ctyunaccountid": "dab4124510dd4xxxxxxxxx5c6a6db69",
"ctyunregion": "bb9fdb42056xxxxxx0242ac110002"
}
