数据实时同步
2018-06-19 15:19:14 11 举报数据实时同步流程
作者其他创作
大纲/内容
获取kafka数据（多条）
线程
结束
全部处理完成反馈kafka修改offset
按照表名和主键作为key放到Map中
queue
反馈主线程
根据tableName获取Mapping 解析
解析binlog消息与Es index 对应
queue消息全部处理完毕
Map
线程处理开始
操作Es写入
收藏
收藏
职业：本科
0 条评论
下一页
