操作场景
CKafka 连接器提供数据流出能力,您可以将 CKafka 数据分发至时序数据库(CTSDB)以对数据进行存储、查询和分析。
前提条件
该功能目前依赖时序数据库(CTSDB)产品,使用时需开通相关产品功能。
操作步骤
1. 登录 CKafka 控制台。
2. 在左侧导航栏单击连接器 > 任务列表,选择好地域后,单击新建任务。
3. 填写任务名称,任务类型选择数据流出,数据目标类型选择 时序数据库(CTSDB),单击下一步。
4. 配置数据源信息。
Topic 类型:选择数据源 Topic
弹性 Topic:选择提前创建好的弹性 Topic,详情参见 Topic 管理。
CKafka 实例内 Topic:选择在 CKafka 创建好的实例和 Topic,若实例设置了ACL 策略,请确保选中的 topic 有读写权限。详情参见 创建 Topic。
起始位置:选择转储时历史消息的处理方式,topic offset 设置。
5. 设置上述信息后,单击下一步,单击预览 Topic 消息,将会选取源 Topic 中的第一条消息进行解析。
6. (可选)开启对源数据进行数据处理按钮,具体配置方法请参见 简单数据处理。
7. 单击下一步,配置数据目标信息。
数据目标:选择提前创建好的 CTSDB 连接。
metic:选择数据流出的数据库表。
8. 单击提交,可以在任务列表看到刚刚创建的任务,在状态栏可以查看任务创建进度。