Kafka觸發器

Kafka觸發器可以訂閱天翼云提供的分布式消息隊列Kafka實例，并根據消息觸發關聯的工作流，借此能力，使得工作流可以消費指定topic的消息，執行特定工作流處理邏輯。

注意事項

Kafka觸發器訂閱的Kafka實例必須和工作流在相同地域。

前提條件

•  已創建工作流。

•  已開通分布式消息Kafka實例（KAFKA引擎版），詳情請參考創建分布式消息服務Kafka實例。

•  已創建Topic，創建GroupID（可選）

觸發消息格式

Kafka觸發器有兩種消息格式：RawData和CloudEvent格式，可在觸發器配置里選擇。 CloudEvent格式：

[
    {
        "id": "eca53463-6baf-4d56-8f86-cbdb748208ed",
        "source": "ctyun.faas.trigger.kafka",
        "specversion": "1.0",
        "type": "kafka:topic:send-message",
        "datacontenttype": "application/json",
        "subject": "kafka-trigger-mqbjvsezbp-dial-test:test-for-faas",
        "time": "2025-05-22T02:04:16Z",
        "data": {
            "headers": {},
            "timestamp": 1747879456,
            "topic": "test-for-faas",
            "partition": 0,
            "offset": 15280,
            "key": "",
            "value": "msg[9]: 154b2a0e-2c3d-4b03-ae9e-c225b5370c3b, ts=2025-05-22 02:04:16"
        }
    }
]

RawData格式是CloudEvent格式的子集，只包含原始kafka消息的信息，消息結構相當于CloudEvent的data字段

[
  {
    "offset" : 15280,
    "partition" : 0,
    "headers" : {},
    "topic" : "test-for-faas",
    "key" : "testkey",
    "timestamp" : 1747879456,
    "value" : "msg[9]: 154b2a0e-2c3d-4b03-ae9e-c225b5370c3b, ts=2025-05-22 02:04:16"
  }
]

操作步驟

1. 登錄，點擊目標工作流，進入工作流詳情詳情。

2. 在配置選項卡中，選擇左邊的 工作流調度 選項卡。

3. 點擊 創建工作流調度，在彈出的右抽屜中選擇 Kafka觸發器，配置參數解釋如下表。