kafka源码系列之mysql数据增量同步到kafka

一，架构介绍mysql 生产中因为历史缘由web后端，mysql集群，kafka集群(或者其它消息队列)会存在一下三种结构。web 1，数据先入mysql集群，再入kafka面试 数据入mysql集群是不可更改的，如何再高效的将数据写入kafka呢？sql A),在表中存在自增ID的字段，而后根据ID，按期扫描表，而后将数据入kafka。数据库 B),有时间字段的，能够按照时间字段按期扫描入kaf

>>阅读原文<<