tencent cloud

文档反馈

配置 Ckafka 连接器

最后更新时间:2024-01-22 20:52:28

    操作场景

    您可以通过配置 Ckafka 连接器来消费 Ckafka 消息队列的内容。Ckafka 连接器实现方式为 Pull 模型,事件连接器会主动拉取 Ckafka 内容,并将相关事件通过事件规则路由到更多服务。本文为您介绍如何创建 Ckafka 连接器及 Ckafka 连接器生成的事件结构。

    前提条件

    操作步骤

    1. 登录 事件总线控制台,选择左侧导航栏中的事件集
    2. 在“事件集”列表,选择期望配置 Ckafka 连接器的事件集。
    3. 在“事件集详情”页事件连接器配置项中单击添加,如下图所示:
    
    
    4. 根据页面提示填写相关信息,如下图所示:
    
    其中连接器类型选择 消息队列(Kafka) 连接器,其余配置项按照提示填写。
    注意:
    目前只支持云上 Ckafka 实例投递,请确认您的 Ckafka 实例没有配置用户名密码等信息,否则连接器可能无法成功获取消息。
    5. 单击确定完成创建。
    6. 选择左侧导航栏中的事件规则
    7. 在“事件规则”顶部选框,选择与之前创建一致的事件集信息,并单击新建事件规则,如下图所示:
    
    
    8. 根据页面提示填写相关信息,如下图所示:
    
    其中云服务类型选择 消息队列(CKafka),并配置触发目标端。
    9. 单击确定即可创建 Ckafka 连接器。

    Ckafka 连接器生成的事件结构说明

    {
    "specversion":"1.0",
    "id":"13a3f42d-7258-4ada-da6d-023a333b4662",
    "type":"connector:kafka",
    "source":"ckafka.cloud.tencent",
    "subjuect": "qcs::ckafka:ap-guangzhou:uin/1250000000:ckafkaId/uin/1250000000/ckafka-123456",
    "time":"1615430559146",
    "region":"ap-guangzhou",
    "datacontenttype":"application/json;charset=utf-8",
    "data":{
    "topic":"test-topic",
    "Partition":1,
    "offset":37,
    "msgKey":"test",
    "msgBody":"Hello from Ckafka again!"
    }
    }
    参数说明如下:
    参数
    描述
    topic
    Ckafka 投递 Topic。
    Partition
    事件源所在分区,一个 Topic 可以包含一个或者多个 Partition,CKafka 以 Partition 作为分配单位。
    offset
    消费分组,指定消费区域。
    msgKey
    Ckafka 消息 Key。
    msgBody
    Ckafka 消息体。
    联系我们

    联系我们,为您的业务提供专属服务。

    技术支持

    如果你想寻求进一步的帮助,通过工单与我们进行联络。我们提供7x24的工单服务。

    7x24 电话支持