本文介紹如何在事件總線EventBridge管理控制臺添加分布式消息Kafka類型的自定義事件源。

前提條件

事件總線EventBridge

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

• 創建自定義總線。

分布式消息服務Kafka

• 開通分布式消息服務Kafka。

• 創建實例、主題與消費組。

操作步驟

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

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

3. 在事件總線頁面，單擊目標總線名稱。

4. 在左側導航欄，單擊事件源。

5. 在事件源頁面，單擊添加事件源。

6. 在添加自定義事件源面板，輸入名稱和描述，事件提供方選擇分布式消息服務Kafka，選擇實例、主題等配置然后單擊確認，詳見圖1。

   

   圖1 添加事件提供方為分布式消息服務Kafka的事件源

參數說明

事件示例

{
    "id": "7c15fe0b-4933-4206-b1ef-2eae5920e745",
    "source": "source1",
    "specversion": "1.0",
    "subject": "ctyun:kafka:cb36e4faeb0exxxxb3accd9dce88c:topic:source1",
    "time": "2024-12-10T06:40:48.441Z",
    "datacontenttype": "application/json; charset=utf-8",
    "type": "ctyun:kafka:Topic:Message",
    "ctyunregion": "b342b77ef26xxxxxxc0242ac110002",
    "ctyunaccountid": "c0f88154e1xxxxx972139b41cd929b",
    "data": {
        "offset": 51,
        "topic": "source1",
        "value": "test",
        "key": "key1"
    }
}

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