操作场景
您可以通过配置 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 消息体。 |