事件总线EventBridge：自定义事件源消息队列RocketMQ版

操作步骤

1. 登录事件总线EventBridge控制台。
2. 在左侧导航栏，单击事件总线。
3. 在顶部菜单栏，选择地域。
4. 在事件总线页面，单击目标总线名称。
5. 在左侧导航栏，单击事件源。

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

7. 在添加自定义事件源面板，输入名称和描述，事件提供方选择消息队列 RocketMQ 版，配置以下参数，然后单击确认。

   • 地域：选择已创建的云消息队列 RocketMQ 版实例所在的地域。

   • 版本：选择RocketMQ 4.x或者RocketMQ 5.x。

   • RocketMQ 实例：选择已创建的云消息队列 RocketMQ 版实例。

   • Topic：选择已创建的Topic。

   • （可选）Tag：输入过滤标签。

   • Group ID：选择已创建的Group ID。

     说明

     一个Group对应一类业务消息。请确保不同的事件源使用独立的Group ID，且不要与已有业务共用。

   • 消费位点：选择消费位点，默认为最新位点。

事件示例

{
    "id":"94ebc15f-f0db-4bbe-acce-56fb72fb****",
    "source":"acs:mq",
    "specversion":"1.0",
    "type":"mq:Topic:SendMessage",
    "datacontenttype":"application/json; charset=utf-8",
    "subject":"acs:mq:cn-hangzhou:123456789098****:MQ_INST_123456789098****_BXhFHryi%TopicName",
    "time":"2021-04-08T06:01:20.766Z",
    "aliyunpublishtime":"2021-04-08T06:01:20.725Z",
    "aliyuneventbusname":"BusName",
    "data":{
        "topic":"TopicName",
        "systemProperties":{
            "MIN_OFFSET":"0",
            "TRACE_ON":"true",
            "MAX_OFFSET":"8",
            "MSG_REGION":"cn-hangzhou",
            "KEYS":"systemProperties.KEYS",
            "CONSUME_START_TIME":1628577790396,
            "UNIQ_KEY":"AC14C305069E1B28CDFA3181CDA2****",
            "TAGS":"systemProperties.TAGS",
            "INSTANCE_ID":"MQ_INST_123456789098****_BXhFHryi"
        },
        "userProperties":{
        },
        "body":"TEST"
    }
}

CloudEvents规范中定义的参数解释，请参见事件概述。

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