Canal + Kafka經驗

canal中寫入kafka的BUG kafka的默認最大消息大小是1M, canal做者也知道這個事, 因此往canal扔消息的時候, 會先作一個判斷, 若是消息大小>1M, 會報錯 但關鍵是他報錯說的要把kafka的配置改大, 其實是本身作了閹割, 怨不得kafka, 我橫來豎去改了n遍kafka的配置也沒用 目前我作的是修改了canal的源碼:(GITHUB上最新版源碼已經加上了這個配置)ja

>>阅读原文<<