Flink解析kafka canal未壓平數據爲message報錯

canal使用非flatmessage方式獲取mysql bin log日誌發至kafka比直接發送json效率要高不少，數據發到kafka後須要實時解析爲json,這裏能夠使用strom或者flink,公司原本就是使用strom解析，可是在吞吐量上有瓶頸，優化空間不大。因此試一試經過flink來作。html 非flatmessage須要使用特定的反序列化方式來處理爲Message對象，因此這裏須

>>阅读原文<<