Flink 側輸出流拆分流應用

業務場景：使用Flink同步Kafka數據近實時寫入MySQL，須要將登陸數據拆分爲登陸，日活，新增分別入三個MySQL表。 採用側輸出流將流拆分爲多個流，分別進行處理。mysql 主類sql /** * Flink 讀取 Kafka，每秒聚合一次數據，批量寫入 MySQL * * create by LiuJinHe 2020/5/26 */ object CpDataKafka

>>阅读原文<<