本文介绍如何在事件总线EventBridge管理控制台中添加分布式消息服务RocketMQ类型的自定义事件源。

前提条件

事件总线EventBridge

• 开通事件总线EventBridge并委托授权。

• 创建自定义总线。

分布式消息服务RocketMQ

• 开通分布式消息服务RocketMQ。

• 创建实例，并创建对应主题与消费组。

操作步骤

1. 登录事件总线管理控制台。

2. 在左侧导航栏，单击事件总线。

3. 在事件总线页面，单击目标总线名称。

4. 在左侧导航栏，单击事件源。

5. 在事件源页面，单击添加事件源。

6. 在添加自定义事件源面板，输入名称和描述，事件提供方选择分布式消息服务RocketMQ，选择实例、主题等配置然后单击确认，如图1所示。

   

   图1 创建事件源时事件提供方选择分布式消息服务RocketMQ

参数说明

事件示例

{
    "id": "878560b2-0cc5-4c0a-a8fc-8ac0a54d9ad0",
    "specversion": "1.0",
    "source": "source4",
    "type": "rocketmq:Topic:SendMessage",
    "subject": "ctyun:rocketmq:bb9fdb42056xxxxxx0242ac110002:dab4124510dd4xxxxxxxxx5c6a6db69:topic:eb-source",
    "datacontenttype": "application/json",
    "time": "2025-10-30T03:58:30.726000266Z",
    "data": {
        "topic": "eb-source",
        "msgId": "21000D141B0905EF04B597EA3D410001",
        "userProperties": {},
        "systemProperties": {
            "CLUSTER": "825b089b1d75416991ba902740016827",
            "CONSUME_START_TIME": "1761796710725",
            "KEYS": "webtest",
            "MAX_OFFSET": "1",
            "MIN_OFFSET": "0",
            "TAGS": "1761796710719_0",
            "UNIQ_KEY": "21000D141B0905EF04B597EA3D410001"
        },
        "body": "WebTestTools_1761796710719c8Uv4rBkcul8MPAYLKG35feURgVAJkhK"
    },
    "ctyunaccountid": "dab4124510dd4xxxxxxxxx5c6a6db69",
    "ctyunregion": "bb9fdb42056xxxxxx0242ac110002"
}

data字段包含的参数解释如下表所示。

data字段中systemProperties属性的参数解释如下图所示：