操作场景
CKafka 连接器提供数据流出能力，您可以将 CKafka 数据分发至日志服务 CLS 便于解决业务问题定位，指标监控，安全审计等问题。
前提条件
该功能目前依赖 CLS 服务，使用时需开通相关产品功能。
操作步骤
1. 登录 CKafka 控制台。
2. 在左侧导航栏单击连接器 > 任务列表，选择好地域后，单击新建任务。
3. 填写任务名称，任务类型选择数据流出，数据目标类型选择 日志服务（CLS），单击下一步。
4. 配置数据源信息。
Topic 类型：选择数据源 Topic
弹性 Topic：选择提前创建好的弹性 Topic，详情参见 Topic 管理。
CKafka 实例内 Topic：选择在 CKafka 创建好的实例和 Topic，若实例设置了ACL 策略，请确保选中的 topic 有读写权限，详情参见 创建 Topic。
起始位置：选择转储时历史消息的处理方式，topic offset 设置。
5. 设置上述信息后，单击下一步，单击预览 Topic 消息，将会选取源 Topic 中的第一条消息进行解析。
6. （可选）开启对源数据进行数据处理按钮，具体配置方法请参见 简单数据处理。
7. 单击下一步，配置数据目标信息。
源数据：单击点击拉取可以拉取源数据，数据按 JSON 解析后投递。
KEY：源 Topic 内数据不是 JSON 格式时，可以指定 key 组装为 JSON 投递到 CLS 中。默认为 content。
日志集：选择日志集，日志集日志服务的项目管理单元，用于区分不同项目的日志。
日志主题：自动创建日志主题或者选择已有日志主题。一个 日志集 可以包含多个日志主题，一个日志主题对应一类应用或服务，建议将不同机器上的同类日志收集到同一个日志主题。
日志时间：可以指定源数据中的某一字段作为日志时间。
角色授权：使用日志服务（CLS）产品功能，您需要授予一个第三方角色代替您执行访问相关产品权限。
8. 单击提交，可以在任务列表看到刚刚创建的任务，在状态栏可以查看任务创建进度。