CKafka 消息队列

用户可以编写云函数来处理 CKafka 中收取到的消息。云函数后台模块可以作为消费者消费 CKafka 中的消息，并将消息传递给云函数。更多细节请看定腾讯 CKafka 触发器文档。

events: # 触发器
  - ckafka: # ckafka触发器
      parameters:
        qualifier: $DEFAULT # 别名配置
        name: ckafka-xxx
        topic: test
        maxMsgNum: 999
        retry: 10000
        offset: latest
        timeout: 60
        enable: true

triggers:
  - type: ckafka
      function: index
      parameters:
        name: ckafka-xxx
        topic: test
        maxMsgNum: 999
        retry: 10000
        offset: latest
        timeout: 60
        enable: true

配置说明

通常 CKafka 触发器配置包含以下字段，具体的字段和配置方式请参考单函数组件(scf)和多函数组件(multi-scf)的全量配置说明文档。

注意：添加 CKafka 触发器，需要给 SLS_QcsRole 添加 QcloudCKafkaFullAccess 策略。

Ckafka 入参

{
    "Records": [
    {
        "Ckafka": {
        "topic": "test-topic",
        "Partition":1,
        "offset":36,
        "msgKey": "None",
        "msgBody": "Hello from Ckafka!"
        }
    },
    {
        "Ckafka": {
        "topic": "test-topic",
        "Partition":1,
        "offset":37,
        "msgKey": "None",
        "msgBody": "Hello from Ckafka again!"
        }
    }
    ]
}

数据结构内容详细说明如下：