- 一个基于go-mysql &gorail二次开发的binlog解析工具，最终生成SQL语句使用MQ发送到消费者进行执行（这里使用banyandb的Queue可更换成kafka）
- 增加了修改表结构（alter table）和创建库表（create table）后依然能正常工作的特性
- 数据分库处理（后期可能会精确到表）
- 多个mysql实例同时处理的功能
- 解决跨机房mysql自带同步缓慢的问题
-
- 修改了go-mysql源码所以必须使用vendor下的包
- consumer 多实例分库消费，数据保证不丢失
- make
- ./Producer
- ./Consumer
- 在conf目录下修改 producer.toml 配置mysql地址，banyandb集群agent地址和库表，mysql主库可以添加多个同时处理，只要保证id 、data_path和ns table选项不重复即可
- 程序运行后会在conf目录下生成data_path配置的master.info文件，保存binlog文件名 pos号信息
-
- 如果同步遇到drop table、drop database命令或者程序异常中断之后有表结构更改（alter table）命令那么需要删除master.info文件并手动进行全量同步，否则可能出现解析表字段名异常
- 参考producer对应的配置修改 consumer.toml
