自建Apache Kafka事件源
更新时间 2025-12-29 16:49:17
最近更新时间: 2025-12-29 16:49:17
本文介绍如何在事件总线EventBridge管理控制台添加自建Apache Kafka事件源作为事件流中的事件提供方。
前提条件
事件总线EventBridge
操作步骤
登录事件总线管理控制台。
在左侧导航栏，单击事件流。
在事件流页面，单击创建事件流。
在事件源（Source）配置面板，事件提供方选择自建Apache Kafka事件源，选择或填入主题等配置然后单击确认。
参数说明
| 参数 | 说明 | 示例 |
|---|---|---|
| 名称 | 事件源名。 | source1 |
| 接入点 | Apache Kafka集群broker接入点，由IP与端口号拼接而成，以逗号分隔。 | 172.17.0.25:9092,192.17.0.26:9092,172.17.0.27:9092 |
| Topic | topic名称。 | topic1 |
| Group ID | 填入当前Apache Kafka集群中已创建的Group，请不要与已有业务的Group混用，以免影响已有的消息收发。 | group1 |
| 网络配置 | 根据业务场景选择对应配置。
| 专有网络 |
| VPC | 网络配置选择专有网络时必填，选择集群所在的VPC。 | vpc-**** |
| 子网 | 网络配置选择专有网络时必填，选择集群所在的子网。 | subnet-**** |
| 认证模式 | 选择认证模式。
| PLAINTEXT |
| 消费位点 | 消费消息的位点。
| 最新位点 |
| 数据格式 | 消息value数据编码格式。
| JSON |
事件示例
{
"id": "601f1f75-6f8c-4d97-941e-5c04f7add896",
"specversion": "1.0",
"source": "apache:kafka",
"type": "kafka:Topic:SendMessage",
"subject": "apache:kafka:bb9fdb42056xxxxxx0242ac110002:dab4124510dd4xxxxxxxxx5c6a6db69:topic:stream_source",
"datacontenttype": "application/json",
"time": "2025-10-30T07:16:07.692257848Z",
"data": {
"topic": "stream_source",
"partition": 0,
"offset": 36,
"value": "msg-17"
},
"ctyunaccountid": "dab4124510dd4xxxxxxxxx5c6a6db69",
"ctyunregion": "bb9fdb42056xxxxxx0242ac110002"
}data字段包含的参数解释如下表所示：
| 参数 | 类型 | 示例值 | 描述 |
|---|---|---|---|
| topic | String | source1 | Topic名称。 |
| offset | Integer | 1 | 消费位点。 |
| key | String | test | 消息Key值。 |
| value | Object | Hello,Kafka! | 消息体，默认以JSON格式编码。 |
