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

前提條件

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

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

創建開源Kafka觸發器

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

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

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

4、設置以下信息。

• 觸發器類型：選擇“開源Kafka（OPENSOURCEKAFKA）”。
• 連接地址：搭建kafka的broker地址列表，以逗號分隔。
• 主題：用戶自建的topic。
• 批處理大小：單次函數拉取最大數據量。

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

說明
函數網絡配置需要和創建kafka的ecs節點網絡配置一樣，包括vpc和子網。

激活kafka觸發器

開源Kafka觸發器創建完成后默認是停用狀態，需要在觸發器界面上單擊“啟動”。

說明
如果啟動失敗可以聯系技術支持工程師。

配置Kafka事件觸發函數

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

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

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

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

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

表 測試信息

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