本文介紹如何在事件總線EventBridge管理控制臺添加分布式消息服務RocketMQ作為事件流中的事件提供方。

前提條件

事件總線EventBridge

• 開通事件總線EventBridge并委托授權。

分布式消息服務RocketMQ

• 開通分布式消息服務RocketMQ并開通實例。

操作步驟

1. 登錄事件總線管理控制臺。

2. 在左側導航欄，單擊事件流。

3. 在事件流頁面，單擊創建事件流。

4. 在事件源（Source）配置面板，事件提供方選擇分布式消息服務RocketMQ，選擇或填入主題等配置然后單擊確認，如圖1所示。

   

   圖1 創建事件流時選擇分布式消息服務RocketMQ作為事件提供方

參數說明

事件示例

{
    "id": "413305a4-2076-47fc-9443-2639472752be",
    "source": "ctyun:rocketmq",
    "specversion": "1.0",
    "subject": "ctyun:rocketmq:0b3a633836ef43b890df8834233ab4da:topic:source0205",
    "time": "2025-02-05T08:01:47.633357732Z",
    "datacontenttype": "application/json",
    "type": "rocketmq:Topic:SendMessage",
    "ctyunregion": "b342b77efxxxxxxxxxxxxxac110002",
    "ctyunaccountid": "0b3a63383xxxxxxxxxxxxxxxxx4233ab4da",
    "data": {
        "systemProperties": {
            "MIN_OFFSET": "0",
            "MAX_OFFSET": "1",
            "KEYS": "webtest",
            "CONSUME_START_TIME": "1738742507633",
            "CLUSTER": "c967202954xxxxxxxxxxx268bf6222285",
            "UNIQ_KEY": "21001CDC0BExxxxxxxxx806D2460082",
            "TAGS": "1738742300229_0"
        },
        "userProperties": {},
        "topic": "source0205",
        "msgId": "21001CDC0BE805EF04B51806D2460082",
        "body": "WebTestTools_173874230022xxxxxxxxxxxxxxxxxx5gC7OiRAiPNG1NwCig6Fwd9eS"
    }
}

data字段包含的參數解釋如下表所示：

data字段中systemProperties屬性的參數解釋如下圖所示：