一、前提条件
已 创建事件集。
二、操作步骤
1. 登录 事件总线控制台，选择左侧导航栏中的事件集。
2. 在“事件集”列表，选择期望配置 CKafka 连接器的事件集。
3. 在“事件集详情”页事件连接器配置项中单击添加：
4. 根据页面提示填写相关信息，其中连接器类型选择消息队列（CKafka）连接器，其余配置项按照提示填写：
注意：目前只支持云上 CKafka 实例投递，请确认你的 CKafka 实例没有配置用户名密码等信息，否则连接器可能无法成功获取消息。
5. 单击确定完成新建事件连接器。
6. 选择左侧导航栏中的事件规则。
7. 在“事件规则”顶部选框，选择与之前创建一致的事件集信息，并单击新建：
8. 根据页面提示填写相关信息，其中连接器类型选择消息队列（CKafka），信息填写完成后单击下一步。
9. 配置触发目标端，配置完成后单击完成即可。
三、CKafka 连接器生成的事件结构说明
{ "specversion": "0", "id": "8d5c4bc7-3330-49ba-888f-bd2c4c3e6bbe", "source": "ckafka.cloud.tencent", "type": "connector:ckafka", "subject": "qcs::ckafka:ap-guangzhou:uin/1250000000:ckafkaId/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 | CKafka 消息偏移量/位移。 |
| msgKey | CKafka 消息 Key。 |
| msgBody | CKafka 消息体。 |