操作场景
CKafka 连接器支持接入各种数据源产生的不同类型的数据，统一管理，再分发给下游的离线/在线处理平台，构建清晰的数据通道。
CKafka 连接器支持订阅 MySQL 变更数据，免去对基于 CDC 的订阅组件如（Canal、Debezium 等）的运维成本。本文介绍在 CKafka 控制台创建 MySQL 数据接入任务的操作方法。
前提条件
已创建好数据目标 Topic。
已创建好数据源 MySQL 连接。
操作步骤
1. 登录 CKafka 控制台。
2. 在左侧导航栏选择连接器 > 任务列表，选择好地域后，单击新建任务。
3. 填写任务名称，任务类型选择数据接入，数据目标类型选择 MySQL 数据订阅，单击下一步。
4. 填写数据源配置信息。
参数 | 说明 |
数据源 | 选择提前创建好的 MySQL 源数据连接 |
选择数据库表 | 支持三种选择方式： 全部库表：订阅该连接关联的所有数据库表。 批量选择：支持手动勾选要订阅的数据库和表，支持订阅多个数据库、多个表。 正则匹配：支持使用正则匹配筛选订阅符合条件的整库或者表。 |
5. （可选）设置高级参数。
参数 | 说明 |
时区 | 支持选择时区。 |
复制存量数据 | 开启后将复制源 MySQL 数据库中的存量数据，开关一经打开，无论后续是否关闭，都无法新增需要监听的库。 |
订阅结构更新 | 订阅结构更新将订阅整个数据库实例所有对象的结构创建，删除以及修改。若数据目标配置选择分发到多个Topic 则不支持订阅结构更新。 |
发送墓碑消息 | 在删除源记录后，如果配置 true，则会发送 value 为空的墓碑消息。 |
包含原始 SQL 查询 | 是否包含生成变更事件的原始 SQL 查询。需要 MySQL 的配置项"binlog_rows_query_log_events"的值为"ON"。 |
分区策略 | 订阅数据写入，默认情况下根据主键 hash 到不同的分区。可以手动指定表的 hash 字段。 |
数据格式 | 默认采用 Debezium 格式，同时提供了兼容其他消息格式的能力。 Canal 格式：详情介绍请参见 MySQL 订阅消息 Canal 格式说明。 官方格式一：详情介绍请参见 MySQL 订阅消息官方格式说明。 |
6. 单击下一步，配置数据目标信息。分发到多个 Topic：支持将不同数据库表中的数据分发到不同的 Topic 中去。
开启后：支持自动创建 Topic 或者选择已有 Topic。
自动创建 Topic：只能自动创建 CKafka Topic，自动创建的 topic 名是由 database.schema.table 形式构建。
选择已有 Topic：只能选择同一个 CKafka 实例下的 Topic。
未开启：支持自动创建 Topic 或者选择已有 Topic。
自动创建 Topic：可以选择 CKafka 实例内 Topic 或者弹性 Topic，若选择 CKafka 实例内 Topic，则需要指定目标 CKafka 实例。支持批量连续命名或指定模式串命名，参考文档。
选择已有 Topic：支持选择 弹性 Topic 或者 CKafka 实例内 Topic。选择 CKafka 实例内 Topic 时，若实例设置了 ACL 策略，请确保选中的 Topic 有读写权限。
7. 选择是否开启数据压缩，数据压缩可以减少网络 IO 传输量，减少磁盘存储空间，数据压缩说明。
8. 单击提交，可以在任务列表看到刚刚创建的任务，在状态栏可以看到创建进度。
新增订阅表
MySQL 数据库订阅任务支持新增订阅的表。当用户在编辑数据源勾选新增订阅的表时：
若原任务在配置数据目标时选择了分发到多个 Topic，则新增订阅表后，需要编辑数据目标，为新增订阅的表指派分发到的 Topic；
若新增的订阅表需要复制存量数据，可以在编辑时打开“复制存量数据”开关。需要设置信息如下：
复制存量数据：选择是否开启复制存量数据开关。开关只对新增监听的表生效。对任务中已经监听的表，仍维持原有采集逻辑。
存放信令表的数据库名称：开启复制存量数据开关时需要勾选存放信令表的数据库。请确保连接管理中配置的用户拥有该数据库的创建、修改、删除表的权限（仅用于对信令表的操作）。关于信令表请参见 什么是信令表。