基于事件流实现Kafka消息路由

1. 在Source（源）配置向导，选择数据提供方为消息队列 Kafka 版，设置以下参数，然后单击下一步。

   参数	说明	示例
   地域	选择云消息队列 Kafka 版源实例所在的地域。	华北2（北京）
   kafka 实例	选择生产云消息队列 Kafka 版消息的源实例。	MQ_INST_115964845466****_ByBeUp3p
   Topic	选择生产云消息队列 Kafka 版消息的Topic。	topic
   Group ID	选择源实例的消费组名称。请使用独立的消费组来创建事件源，不要和已有的业务混用消费组，以免影响已有的消息收发。	GID_http_1
   并发配额（消费者数）	选择源实例的消费者数。	1
   消费位点	选择开始消费消息的位点。	最新位点
   网络配置	选择路由消息的网络类型。	默认网络
   专有网络VPC	选择VPC ID。当网络配置设置为自建公网时需要设置此参数。	vpc-bp17fapfdj0dwzjkd****
   交换机	选择vSwitch ID。当网络配置设置为自建公网时需要设置此参数。	vsw-bp1gbjhj53hdjdkg****
   安全组	选择安全组。当网络配置设置为自建公网时需要设置此参数。	alikafka_pre-cn-7mz2****
   数据格式	数据格式是针对支持二进制传递的数据源端推出的指定内容格式的编码能力。针对消息路由场景，这里配置参数为Binary。	Binary
   批量推送	批量推送可帮您批量聚合多个事件，当批量推送条数和批量推送间隔（单位：秒）两者条件达到其一时即会触发批量推送。 例如：您设置的推送条数为100 条，间隔时间为15 s，在10 s内消息条数已达到100条，那么该次推送则不会等15 s后再推送。	开启
   批量推送条数	调用函数发送的最大批量消息条数，当积压的消息数量到达设定值时才会发送请求，取值范围为 [1,10000]。	100
   批量推送间隔（单位：秒）	调用函数的间隔时间，系统每到间隔时间点会将消息聚合后发给函数计算，取值范围为[0,15]，单位为秒。0秒表示无等待时间，直接投递。	3

2. 在Filtering（过滤）配置向导，设置事件过滤规则，单击下一步。

   说明

   在当前文档配置下，无法根据消息value的特定内容进行过滤。消息路由场景无需配置Transform（转换）。

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

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

设置事件流的重试策略及死信队列。更多信息，请参见重试和死信。