本文介绍如何在事件总线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字段包含的参数解释如下表所示。