您可以通過事件規則過濾事件，將事件路由到分布式消息服務Kafka。本文以自定義事件為例介紹將事件路由到分布式消息服務Kafka的前提條件、操作步驟和結果驗證。

前提條件

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

• 創建自定義總線服務。

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

操作步驟

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

2. 選擇目標總線，點擊事件源按鈕，點擊添加事件源按鈕，創建一個自定義事件源；填寫事件源名，事件提供方可選擇自定義應用。

3. 在左側導航欄，單擊事件規則，然后單擊添加事件規則。

4. 在添加事件規則頁面，完成以下操作，如圖1所示。

   1. 在配置基本信息配置向導頁面中，在名稱文本框輸入規則名稱，在描述文本框輸入規則的描述，然后單擊下一步。

   2. 在配置事件模式配置向導頁面中，事件源類型選擇自定義事件源，事件源選擇對應的自定義事件源，在事件模式內容代碼框輸入事件模式，這里可選擇匹配全部事件，然后單擊下一步。

   3. 在配置事件目標配置向導，配置事件目標，分布式消息服務Kafka目標參數描述如下，然后單擊創建。

      

      圖1 創建事件規則時服務類型選擇分布式消息服務Kafka

參數說明

結果驗證

1. 使用事件總線事件發布功能，發送一個自定義事件。

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

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

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

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

      

      圖2 在分布式消息服務Kafka管理控制臺消息查詢界面查詢消息