路由到云消息隊(duì)列 Kafka 版
本文介紹如何在事件總線EventBridge控制臺添加云消息隊(duì)列 Kafka 版作為事件流中的服務(wù)類型。
前提條件
您已購買并部署云消息隊(duì)列 Kafka 版實(shí)例，且實(shí)例處于服務(wù)中狀態(tài)。具體步驟，請參見購買和部署實(shí)例。
創(chuàng)建事件流
- 登錄事件總線EventBridge控制臺，在左側(cè)導(dǎo)航欄，單擊事件流。
- 在頂部菜單欄，選擇地域，然后單擊創(chuàng)建事件流。
在創(chuàng)建事件流面板，設(shè)置任務(wù)名稱和描述，配置以下參數(shù)，然后單擊保存。
任務(wù)創(chuàng)建
在Source（源）、Filtering（過濾）、Transform（轉(zhuǎn)換）配置向?qū)ВO(shè)置事件過濾、轉(zhuǎn)換規(guī)則，單擊下一步。事件轉(zhuǎn)換的配置說明，請參見使用函數(shù)計(jì)算實(shí)現(xiàn)消息數(shù)據(jù)清洗。
在Sink（目標(biāo)）配置向?qū)Вx擇服務(wù)類型為消息隊(duì)列Kafka版，配置以下參數(shù)。
參數(shù)
說明
示例
實(shí)例ID
選擇已創(chuàng)建的云消息隊(duì)列 Kafka 版實(shí)例。
test
Topic
選擇已創(chuàng)建實(shí)例中的Topic。
test
確認(rèn)模式（ack）
選擇云消息隊(duì)列 Kafka 版接收到數(shù)據(jù)后給客戶端發(fā)出的確認(rèn)信號。
None
消息體（Value）
事件總線EventBridge通過JSONPath提取事件中的數(shù)據(jù)，將指定的事件內(nèi)容路由到事件目標(biāo)。
部分事件
$.data.value消息鍵值（Key）
事件總線EventBridge通過JSONPath提取事件中的數(shù)據(jù)，將指定的事件內(nèi)容路由到事件目標(biāo)。
部分事件
$.data.key
任務(wù)屬性
設(shè)置事件流的重試策略及死信隊(duì)列。更多信息，請參見重試和死信。
返回事件流頁面，找到創(chuàng)建好的事件流，在其右側(cè)操作欄，單擊啟用。
啟用事件流后，會有30秒~60秒的延遲時(shí)間，您可以在事件流頁面的狀態(tài)欄查看啟動進(jìn)度。
結(jié)果驗(yàn)證
登錄云消息隊(duì)列 Kafka 版控制臺，在概覽頁面的資源分布區(qū)域，選擇地域。
在左側(cè)導(dǎo)航欄，單擊實(shí)例列表，然后在目標(biāo)實(shí)例的操作列單擊詳情。
在左側(cè)導(dǎo)航欄，單擊Topic 管理，然后單擊目標(biāo)Topic名稱。
在Topic詳情頁面，單擊消息查詢頁簽，配置查詢參數(shù)，然后單擊查詢。
