java實操｜mysql數據增量同步到kafka

一，架構介紹mysql 生產中因爲歷史緣由web後端，mysql集羣，kafka集羣(或者其它消息隊列)會存在一下三種結構。web 1，數據先入mysql集羣，再入kafkasql 數據入mysql集羣是不可更改的，如何再高效的將數據寫入kafka呢？數據庫 A),在表中存在自增ID的字段，而後根據ID，按期掃描表，而後將數據入kafka。json B),有時間字段的，能夠按照時間字段按期掃描入k

>>阅读原文<<