本文介紹如何在事件總線EventBridge管理控制臺添加分布式消息服務Kafka作為事件流中的事件目標。

前提條件

• 開通事件總線EventBridge并委托授權。

• 開通分布式消息服務Kafka并創建實例，并創建對應的主題。

創建事件流

1. 登錄事件總線EventBridge管理控制臺，在左側導航欄，單擊事件流。

2. 在創建事件流面板，設置任務名稱和描述，配置以下參數，然后單擊創建，如圖1所示。

   1.   在Source（源）、Filtering（過濾）、Transform（轉換）配置向導，設置事件提供方、事件過濾、轉換規則，單擊下一步。

   2.   在Sink（目標）配置向導，選擇服務類型分布式消息服務Kafka，配置參數，詳見下方參數說明。

3. 創建事件流后，會有30秒~60秒的延遲時間，您可以在事件流頁面的狀態欄查看啟動進度。

   

   圖1 創建事件流中選擇分布式消息服務Kafka為服務類型

參數說明

$.data.value

$.data.value

結果驗證

1. 使用事件源觸發一個事件。

2. 您可以在分布式消息服務Kafka管理控制臺確認是否接收到事件，如圖2所示。

   1. 登錄分布式消息服務Kafka管理控制臺，然后在左側導航欄選擇實例列表。

   2. 在實例列表頁面單擊目標實例名稱。

   3. 在消息查詢頁面，進行對應消息查詢即可查看消息內容。

      

      圖2 在分布式消息服務Kafka管理控制臺中查看消息詳情