本教程將介紹如何使用 Flink CDC 來實現(xiàn)這個需求, 在 Flink SQL CLI 中進行,只涉及 SQL,無需一行 Java/Scala 代碼,也無需安裝 IDE。 系統(tǒng)的整體架構(gòu)如下圖所示:
環(huán)境篇
1、 準備一臺Linux?
2、準備教程所需要的組件
下載 flink-1.13.2 并將其解壓至目錄 flink-1.13.2
tar zxvf flink-1.13.2-bin-scala_2.12.tgz
? flink-1.13.2-bin-scala_2.12.tgz
鏈接:百度網(wǎng)盤 請輸入提取碼 提取碼:az82
下載下面列出的依賴包,并將它們放到目錄 flink-1.13.2/lib/ 下:
? flink-sql-connector-mysql-cdc-2.1.0.jar
? flink-sql-connector-postgres-cdc-2.1.0.jar
? flink-sql-connector-mongodb-cdc-2.1.0.jar
? flink-sql-connector-elasticsearch7_2.11-1.13.2.jar
? flink-sql-connector-kafka_2.12-1.13.5.jar文章來源:http://www.zghlxwxcb.cn/news/detail-708669.html
? flink-shaded-hadoop-2-uber-2.7.5-10.0.jar文章來源地址http://www.zghlxwxcb.cn/news/detail-708669.html
到了這里,關(guān)于Flink CDC 菜鳥教程 -環(huán)境篇的文章就介紹完了。如果您還想了解更多內(nèi)容,請在右上角搜索TOY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章,希望大家以后多多支持TOY模板網(wǎng)!