路由到消息队列Kafka版

本文介绍如何在事件总线EventBridge控制台添加消息队列Kafka版作为事件流中的服务类型。

创建事件流

1. 登录事件总线EventBridge控制台，在左侧导航栏，单击事件流。
2. 在顶部菜单栏，选择地域，然后单击创建事件流。
3. 在创建事件流面板，配置以下参数，然后单击创建。
   1. 在基本信息页签，设置事件流名称和描述，单击下一步。
   2. 在事件源页签和规则页签，设置事件源和事件规则，然后单击下一步。
   3. 在目标页签，选择服务类型为消息队列Kafka版，设置以下参数，然后单击创建。

      参数	说明	示例
      实例 ID	选择已创建的消息队列Kafka版实例。	test
      Topic	选择已创建实例中的Topic。	test
      确认模式	选择消息队列Kafka版接收到数据后给客户端发出的确认信号。	None
      消息内容	事件总线EventBridge通过JSONPath提取事件中的数据，将指定的事件内容路由到事件目标。	部分事件 $.data.value
      消息 Key	事件总线EventBridge通过JSONPath提取事件中的数据，将指定的事件内容路由到事件目标。	部分事件 $.data.key

   4. 返回事件流页面，找到创建好的事件流，在其右侧操作列，单击启用。
      启用事件流后，会有30秒~60秒的延迟时间，您可以在事件流页面的状态栏查看启动进度。

结果验证

1. 登录消息队列Kafka版控制台，在概览页面的资源分布区域，选择地域。
2. 在左侧导航栏，单击实例列表，然后在目标实例的操作列单击详情。
3. 在左侧导航栏，单击Topic 管理，然后单击目标Topic名称。
4. 在Topic详情页面，单击消息查询页签，配置查询参数，然后单击查询。