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

一，架构介绍 生产中由于历史原因web后端，mysql集群，kafka集群(或者其它消息队列)会存在一下三种结构。 1，数据先入mysql集群，再入kafka 数据入mysql集群是不可更改的，如何再高效的将数据写入kafka呢？ A),在表中存在自增ID的字段，然后根据ID，定期扫描表，然后将数据入kafka。 B),有时间字段的，可以按照时间字段定期扫描入kafka集群。 C),直接解析bin

>>阅读原文<<