Flink 侧输出流拆分流应用

业务场景：使用Flink同步Kafka数据近实时写入MySQL，须要将登陆数据拆分为登陆，日活，新增分别入三个MySQL表。 采用侧输出流将流拆分为多个流，分别进行处理。mysql 主类sql /** * Flink 读取 Kafka，每秒聚合一次数据，批量写入 MySQL * * create by LiuJinHe 2020/5/26 */ object CpDataKafka

>>阅读原文<<