使用Kafka觸發器后，FunctionGraph會定期輪詢Kafka實例指定Topic下的新消息，FunctionGraph將輪詢得到的消息作為參數傳遞來調用函數。

前提條件

進行操作之前，需要做好以下準備。

• 已經創建函數。
• 創建Kafka觸發器，必須開啟函數工作流VPC訪問，請參見配置網絡。
• 已經創建Kafka實例。
• 在Kafka實例下創建主題。

創建Kafka觸發器

1、登錄函數工作流控制臺，在左側的導航欄選擇“函數 > 函數列表”。

2、選擇待配置的函數，單擊進入函數詳情頁。

3、選擇“設置 > 觸發器”，單擊“創建觸發器”，彈出“創建觸發器”對話框。

4、設置以下信息。

• 觸發器類型：選擇“分布式消息服務（Kafka）”。
• 實例：選擇已創建專享版Kafka實例。
• 主題：選擇專享版Kafka實例的Topic。
• 批處理大小：每次從Topic消費的消息數量。
• 用戶名：Kafka實例開啟SSL時需要填寫。連接Kafka專享版實例的用戶名。
• 密碼：Kafka實例開啟SSL時需要填寫。連接Kafka專享版實例的密碼。

5、單擊“確定”，完成kafka觸發器的創建。

說明
開啟函數流VPC訪問后，需要在Kafka服務安全組配置對應子網的權限。如何開啟VPC訪問請參見配置網絡。
Kafka觸發器當前支持選擇多個Topic主題，從而避免Topic過多導致創建的觸發器數量被限制。

配置Kafka事件觸發函數。

1、返回函數工作流控制臺，在左側的導航欄選擇“函數 > 函數列表”。

2、選擇待配置的函數，單擊進入函數詳情頁。

3、在函數詳情頁，選擇函數版本。

4、在“代碼”頁簽下，單擊“測試”，彈出“配置測試事件”對話框。

5、填寫如下表示測試信息后，單擊“保存”。

測試信息

6、單擊“測試”，可以得到函數運行結果，函數會返回輸入kafka消息數據。