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触发器，配置参数解释如下表。