自定义自建Apache Kafka事件源
更新时间 2025-12-29 16:45:07
最近更新时间: 2025-12-29 16:45:07
本文介绍如何在事件总线EventBridge管理控制台中添加自建Apache Kafka类型的自定义事件源。
前提条件
事件总线EventBridge
您已部署Apache Kafka集群，并在您的天翼云VPC内或公共网络可访问集群接入点。
操作步骤
登录事件总线管理控制台。
在左侧导航栏，单击事件总线。
在事件总线页面，单击目标总线名称。
在左侧导航栏，单击事件源。
在事件源页面，单击添加事件源。
在添加自定义事件源面板，输入名称和描述，事件提供方选择自建Apache Kafka，配置相关参数，然后单击确认，如图1所示。
图1 创建事件源时事件提供方选择自建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": "source1",
"type": "apachekafka: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"
}
