Flink 1.9 實戰(zhàn)：使用 SQL 讀取 Kafka 并寫入 MySQL

上周六在深圳分享了《Flink SQL 1.9.0 技術(shù)內(nèi)幕和最佳實踐》，會后許多小伙伴對最后演示環(huán)節(jié)的 Demo
代碼非常感興趣，迫不及待地想嘗試下，所以寫了這篇文章分享下這份代碼。希望對于 Flink SQL 的初學者能有所幫助。完整分享可以觀看 Meetup 視頻回顧
：https://developer.aliyun.com/live/1416 <https://developer.aliyun.com/live/1416>

演示代碼已經(jīng)開源到了 GitHub 上：https://github.com/wuchong/flink-sql-submit
<https://yq.aliyun.com/go/articleRenderRedirect?url=https%3A%2F%2Fgithub.com%2Fwuchong%2Fflink-sql-submit>

這份代碼主要由兩部分組成：1) 能用來提交 SQL 文件的 SqlSubmit 實現(xiàn)。2） 用于演示的 SQL 示例、Kafka 啟動停止腳本、
一份測試數(shù)據(jù)集、Kafka 數(shù)據(jù)源生成器。

通過本實戰(zhàn)，你將學到：

* 如何使用 Blink Planner
* 一個簡單的 S

• ? 上一篇：Java日志框架SLF4J和log4j以及l(fā)ogback的聯(lián)系和區(qū)別
• ? 下一篇：是時候讓大家看看你用django寫出來的博客了（內(nèi)含部署教程視頻）