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

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

>>阅读原文<<