本文介绍如何在事件总线EventBridge管理控制台添加分布式消息服务Kafka作为事件流中的事件目标。

前提条件

• 开通事件总线EventBridge并委托授权。

• 开通分布式消息服务Kafka并创建实例，并创建对应的主题。

创建事件流

1. 登录事件总线EventBridge管理控制台，在左侧导航栏，单击事件流。

2. 在创建事件流面板，设置任务名称和描述，配置以下参数，然后单击创建，如图1所示。

   1.   在Source（源）、Filtering（过滤）、Transform（转换）配置向导，设置事件提供方、事件过滤、转换规则，单击下一步。

   2.   在Sink（目标）配置向导，选择服务类型分布式消息服务Kafka，配置参数，详见下方参数说明。

3. 创建事件流后，会有30秒~60秒的延迟时间，您可以在事件流页面的状态栏查看启动进度。

   

   图1 创建事件流中选择分布式消息服务Kafka为服务类型

参数说明

$.data.value

$.data.value

结果验证

1. 使用事件源触发一个事件。

2. 您可以在分布式消息服务Kafka管理控制台确认是否接收到事件，如图2所示。

   1. 登录分布式消息服务Kafka管理控制台，然后在左侧导航栏选择实例列表。

   2. 在实例列表页面单击目标实例名称。

   3. 在消息查询页面，进行对应消息查询即可查看消息内容。

      

      图2 在分布式消息服务Kafka管理控制台中查看消息详情