主要作用是同步mysql数据库至hbase，kudu等存储系统。
- canal日志解析，kafka持久化消息
- 消费kafka消息同步至hbase等存储引擎
- mysql的数据同步支持DDL、DML至hbase
carrygo解析及存储服务主要有两个模块，分别是parser和store。
- 基于canal解析mysql的binlog，批量获取message的entry
- 过滤出需同步的db，并解析数据流，同步到kafka中
- 基于topic接受kafka的消息
- HBaseWriter解析数据并存储
canal：https://github.com/alibaba/canal
- CarryServer服务不可用导致queue数据丢失，存储batchId至zookeeper并记录消费的batchId，丢失就rollback。
- 添加CarrygoManager，CarrgoMonitor服务。
- 添加管理控制台。