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

前提條件

事件總線EventBridge

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

分布式消息服務Kafka

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

操作步驟

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

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

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

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

   

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

參數說明

事件示例

{
    "id": "c40c8fe2-8999-4177-b5ae-d37466bae2e5",
    "source": "ctyun:kafka",
    "specversion": "1.0",
    "subject": "ctyun:kafka:b342b77ef26b11ecbxxxxxxxc110002:0b3a633836ef4xxxxxx33ab4da:topic:stream_source",
    "time": "2025-02-06T03:44:55.026774053Z",
    "datacontenttype": "application/json",
    "type": "kafka:Topic:SendMessage",
    "ctyunregion": "b342b77ef26b11ecbxxxxxxxc110002",
    "ctyunaccountid": "0b3a633836ef4xxxxxx33ab4da",
    "data": {
        "offset": 1,
        "topic": "stream_source",
        "value": "Hello,Kafka!",
        "key": "test"
    }
}

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