发明公开
- 专利标题： 一种基于flink的实时数据同步方法
-
申请号： CN202210155486.0申请日： 2022-02-21
-
公开(公告)号： CN114547197A公开(公告)日： 2022-05-27
- 发明人: 田浩 , 路国隋 , 李存冰 , 陈焕新
- 申请人： 浪潮软件科技有限公司
- 申请人地址： 山东省济南市高新区浪潮路1036号浪潮科技园
- 专利权人： 浪潮软件科技有限公司
- 当前专利权人： 浪潮软件科技有限公司
- 当前专利权人地址： 山东省济南市高新区浪潮路1036号浪潮科技园
- 代理机构： 济南信达专利事务所有限公司
- 代理商 孙晶伟
- 主分类号： G06F16/27
- IPC分类号： G06F16/27 ; G06F16/25 ; G06F9/54 ; G06F16/18 ; G06F11/14
摘要：
本发明公开一种基于flink的实时数据同步方法,涉及数据同步技术领域；制定并启动基于flink的增量同步任务，将同步源端数据变更日志实时采集至kafka消息队列，制定并启动基于flink的增量消费任务，将kafka消息队列中的同步源端数据变更日志信息实时消费，并写入至同步目标数据端。
