赞
踩
1,引入Flink相关依赖包 2,项目启动的时候实现Flink持续处理数据的过程 3,创建类MySink继承RichSinkFunction类,实现处理数据的方法
4,综上所述即为springboot整合Flink的步骤,实现了从接收数据到处理数据的全过程。