如何配置事件流的服务类型为Kafka_事件总线(EventBridge)-阿里云帮助中心

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

前提条件

在创建事件流面板，设置任务名称和描述，配置以下参数，然后单击保存。

任务创建

在Source（源）、Filtering（过滤）、Transform（转换）配置向导，设置事件过滤、转换规则，单击下一步。事件转换的配置说明，请参见使用函数计算实现消息数据清洗。

在Sink（目标）配置向导，选择服务类型为消息队列Kafka版，配置以下参数。

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

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