java实操｜mysql数据增量同步到kafka

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

>>阅读原文<<