分布式消息服务Kafka事件目标
更新时间 2025-06-18 17:55:19
最近更新时间: 2025-06-18 17:55:19
您可以通过事件规则过滤事件,将事件路由到分布式消息服务Kafka。本文以自定义事件为例介绍将事件路由到分布式消息服务Kafka的前提条件、操作步骤和结果验证。
前提条件
开通分布式消息服务Kafka实例,创建实例并创建相应的主题。
操作步骤
登录事件总线EventBridge控制台,在左侧导航栏,单击事件总线。
选择目标总线,点击事件源按钮,点击添加事件源按钮,创建一个自定义事件源;填写事件源名,事件提供方可选择自定义应用。
在左侧导航栏,单击事件规则,然后单击添加事件规则。
在添加事件规则页面,完成以下操作,如图1所示。
在配置基本信息配置向导页面中,在名称文本框输入规则名称,在描述文本框输入规则的描述,然后单击下一步。
在配置事件模式配置向导页面中,事件源类型选择自定义事件源,事件源选择对应的自定义事件源,在事件模式内容代码框输入事件模式,这里可选择匹配全部事件,然后单击下一步。
在配置事件目标配置向导,配置事件目标,分布式消息服务Kafka目标参数描述如下,然后单击创建。
图1 创建事件规则时服务类型选择分布式消息服务Kafka
参数说明
参数 | 说明 | 示例 |
---|---|---|
实例 | 选择分布式消息服务Kafka实例。 | instance-xxx |
Topic | 选择分布式消息服务Kafka实例的Topic。 | topic1 |
消息体 | 选择消息体(Body)的内容,更多信息请参考事件内容转换。 | 完整事件 |
消息键值 | 选择消息键值(Key)的内容,更多信息请参考事件内容转换。 | 空 |
结果验证
使用事件总线事件发布功能,发送一个自定义事件。
您可以在分布式消息服务Kafka管理控制台确认是否接收到事件,如图2所示。
登录分布式消息服务Kafka管理控制台,然后在左侧导航栏选择实例列表。
在实例列表页面单击目标实例名称。
在消息查询页面,进行对应消息查询即可查看消息内容。
图2 在分布式消息服务Kafka管理控制台消息查询界面查询消息