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

設置事件流的重試策略及死信隊列。更多信息，請參見重試和死信。