Flink CDC

課程介紹

Flink CDC是Flink社區(qū)開發(fā)的Flink-cdc-connector組件，是一個(gè)可以實(shí)現(xiàn)從MySQL、PostgreSQL等數(shù)據(jù)庫直接讀取全量數(shù)據(jù)和增量變更數(shù)據(jù)的source組件。通過使用Flink CDC，搭配Flink的流批一體數(shù)據(jù)計(jì)算引擎，能夠?qū)崿F(xiàn)采集計(jì)算一體化，更加方便項(xiàng)目的需求開發(fā)和后續(xù)維護(hù)。

本套視頻教程理論與實(shí)踐相結(jié)合，從Flink CDC的基本使用入手，分別講解了DataStream方式和FlinkSQL方式兩種使用模式，并詳細(xì)講解了如何自定義反序列化器。更為用戶調(diào)研了Flink的Flink CDC 2.0，基于1.x的技術(shù)痛點(diǎn)，2.0給出了更優(yōu)化的解決方案，教程結(jié)合源碼深入分析了其核心原理。