配置 Ckafka 连接器

最近更新时间:2024-07-10 17:56:21

我的收藏

操作场景

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

前提条件

操作步骤

1. 登录 事件总线控制台,选择左侧导航栏中的事件集
2. 在“事件集”列表,选择期望配置 Ckafka 连接器的事件集。
3. 在“事件集详情”页事件连接器配置项中单击添加,如下图所示:



4. 根据页面提示填写相关信息,其中连接器类型选择消息队列(CKafka)连接器,其余配置项按照提示填写,如下图所示:



注意
目前只支持云上 Ckafka 实例投递,请确认您的 Ckafka 实例没有配置用户名密码等信息,否则连接器可能无法成功获取消息。
5. 单击确定完成创建。
6. 选择左侧导航栏中的事件规则
7. 在“事件规则”顶部选框,选择与之前创建一致的事件集信息,并单击新建,如下图所示:


8. 根据页面提示填写相关信息,其中连接器类型选择消息队列(CKafka),信息填写完成后单击下一步



9. 配置触发目标端,配置完成后单击完成即可创建 Ckafka 连接器。




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

{
"specversion": "0",
"id": "8d5c4bc7-3330-49ba-888f-bd2c4c3e6bbe",
"source": "ckafka.cloud.tencent",
"type": "connector:ckafka",
"subject": "qcs::ckafka:ap-guangzhou:uin/1250000000:ckafkaId/uin/1250000000/ckafka-123456",
"time": 1678268812575,
"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 消息体。