消息队列RocketMQ版

操作步骤

1. 登录事件总线EventBridge控制台，在左侧导航栏，单击事件流。
2. 在顶部菜单栏，选择地域，然后单击创建事件流。
3. 在创建事件流面板，配置以下参数，然后单击创建。
   1. 在基本信息页签，设置事件流名称和描述，单击下一步。
   2. 在事件源页签，选择事件提供方为消息队列 RocketMQ 版，设置以下参数，然后单击下一步。

      参数	说明	示例
      地域	选择消息队列RocketMQ版源实例所在的地域。	华东1（杭州）
      RocketMQ 实例	选择生产消息队列RocketMQ版消息的源实例。	MQ_INST_115964845466****_ByBeUp3p
      Topic	选择生产消息队列RocketMQ版消息的Topic。	topic
      Tag	配置源实例中用于过滤消息的Tag。	test
      Group ID	选择源实例中的消费组名称。请使用独立的消费组来创建事件源，不要和已有的业务混用消费组，以免影响已有的消息收发。	GID_http_1
      消费位点	选择开始消费消息的位点。	最新位点

   3. 在规则和目标页签，分别设置事件规则和事件目标。
   4. 返回事件流页面，找到创建好的事件流，在其右侧操作栏，单击启用。
      启用事件流后，会有30秒~60秒的延迟时间，您可以在事件流页面的状态栏查看启动进度。

事件示例

{
    "specversion":"1.0",
    "id":"94ebc15f-f0db-4bbe-acce-56fb72fb****",
    "source":"acs:mq",
    "type":"mq:Topic:SendMessage",
    "subject":"acs:mq:cn-hangzhou:123456789098****:MQ_INST_123456789098****_BXhFHryi%TopicName",
    "datacontenttype":"application/json; charset=utf-8",
    "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字段包含的参数解释如下表所示。