功能：提供数据结构、全量、增量的数据同步功能，提供行级并发同步模式；提供多种下游数据冲突处理模式；提供列级、行级数据过滤及数据映射 功能健壮性：支持全量、增量同步的断点续传； 服务高可用： 1.服务节点故障感知 2.故障节点自动切换 3.异常任务自动迁移 功能描述 数据同步源、目标端类型支持： 上游：mysql 5.7 下游：mysql 5.7、kafka 0.10 (支持0.10版本Kafka集群配置SASL访问控制) 数据同步类型支持： 结构同步(仅限于下游为mysql)：包括表、视图等结构对象的语法迁移。异构数据库迁移将源库语法调整为目标库对应的语法。 全量数据迁移：将源库中的所有数据迁移到目标库中，不包含结构对象定义的语法。如果迁移过程中源库有新增数据，且迁移类型只选择了全量迁移，则新增数据不会迁移到目标库。 增量数据迁移：将 源库迁移过程中新增的数据同步到目标库中，主要用于源库和目标库的增量数据实时同步。如果创建数据迁移任务时，同时选择了全量数据迁移和增量数据迁移，则 迁移过程中会先将源库中静态数据迁移到目标库，然后将增量数据同步到目标库。增量数据迁移不会自动结束，如果需要结束需要手工停止。 同步规则支持： 映射：支持库、表、列级别名称映射，上下游库、表、列名称可不一致 列筛选：支持表内指定列的同步 注意：当主键列由于黑白名单被过滤掉时，则使用所有需要同步的列构成下游SQL的where条件 黑名单：指定列不同步 白名单：指定列同步 行筛选：支持where条件筛选 列类型为整型(各类int)、char、varchar 比较符为=,!=,>,>=,

用于管控业务对 mysql 集群的访问 读写分离 权限管控 分组功能支持 流量负载均衡 账号管理 配置热加载 客户端请求类型对应协议说明： COM_QUIT 关闭连接 handleRollback() Close() https://dev.mysql.com/doc/dev/mysql-server/latest/page_protocol_com_quit.html COM_QUERY SQL查询及 dml、ddl请求 handleQuery() https://dev.mysql.com/doc/dev/mysql-server/latest/page_protocol_com_query.html COM_PING 测试连通性 writeOK() https://dev.mysql.com/doc/dev/mysql-server/latest/page_protocol_com_ping.html COM_INIT_DB 切换数据库 handleUseDB() https://dev.mysql.com/doc/dev/mysql-server/latest/page_protocol_com_init_db.html COM_FIELD_LIST 获取数据表字段信息 handleFieldList() https://dev.mysql.com/doc/dev/mysql-server/latest/page_protocol_com_field_list.html COM_STMT_PREPARE 预处理SQL语句 handleStmtPrepare() https://dev.mysql.com/doc/dev/mysql-server/latest/page_protocol_com_stmt_prepare.html COM_STMT_EXECUTE 执行预处理语句 handleStmtExecute() https://dev.mysql.com/doc/dev/mysql-server/latest/page_protocol_com_stmt_execute.html COM_STMT_CLOSE 销毁预处理语句 handleStmtClose() https://dev.mysql.com/doc/dev/mysql-server/latest/page_protocol_com_stmt_close.html COM_STMT_SEND_LONG_DATA 发送BLOB类型的数据 handleStmtSendLongData() https://dev.mysql.com/doc/dev/mysql-server/latest/page_protocol_com_stmt_send_long_data.html COM_STMT_RESET 清除预处理语句参数缓存 handleStmtReset() https://dev.mysql.com/doc/dev/mysql-server/latest/page_protocol_com_stmt_reset.html COM_SET_OPTION 设置语句选项 handleSetOption() https://dev.mysql.com/doc/dev/mysql-server/latest/page_protocol_com_set_option.html