配置 Ckafka 连接器
操作场景
您可以通过配置 Ckafka 连接器来消费 Ckafka 消息队列的内容。Ckafka 连接器实现方式为 Pull 模型，事件连接器会主动拉取 Ckafka 内容，并将相关事件通过事件规则路由到更多服务。本文为您介绍如何创建 Ckafka 连接器及 Ckafka 连接器生成的事件结构。
前提条件
操作步骤
1. 登录 事件总线控制台，选择左侧导航栏中的事件集。
2. 在“事件集”列表，选择期望配置 Ckafka 连接器的事件集。
3. 在“事件集详情”页事件连接器配置项中单击添加，如下图所示：
4. 根据页面提示填写相关信息，如下图所示：
注意：
目前只支持云上 Ckafka 实例投递，请确认您的 Ckafka 实例没有配置用户名密码等信息，否则连接器可能无法成功获取消息。
5. 单击确定完成创建。
6. 选择左侧导航栏中的事件规则。
7. 在“事件规则”顶部选框，选择与之前创建一致的事件集信息，并单击新建事件规则，如下图所示：
8. 根据页面提示填写相关信息，如下图所示：
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 消息体。 |
文档反馈