kafka源碼系列之mysql數據增量同步到kafka

一，架構介紹 生產中由於歷史原因web後端，mysql集羣，kafka集羣(或者其它消息隊列)會存在一下三種結構。 1，數據先入mysql集羣，再入kafka 數據入mysql集羣是不可更改的，如何再高效的將數據寫入kafka呢？ A),在表中存在自增ID的字段，然後根據ID，定期掃描表，然後將數據入kafka。 B),有時間字段的，可以按照時間字段定期掃描入kafka集羣。 C),直接解析bin

>>阅读原文<<