场景:加载一张资源表,供实时流联查。
方案:资源表较小、不会经常改动,可以用读取这张表进行广播。
实现:实时流正常消费kafka,广播流消费mysql源并做广播,join
不优雅的广播流使用
参考资料:
https://blog.csdn.net/bradyM/article/details/108082903 正确使用Flink广播流以及记录Flink做checkpoints失败情况
https://blog.csdn.net/fct2001140269/article/details/84402798 在使用Flink广播变量broadcast时遇到的坑
https://www.jianshu.com/p/a09827b1d6da Flink中的广播流之BroadcastStream
https://www.cnblogs.com/traveller-hzq/p/14545543.html Flink广播流Demo
https://my.oschina.net/u/3651261/blog/4339904 关于Flink广播流broadcast的一点思考验证
http://www.manongjc.com/article/43464.html Flink的流广播(Broadcast State)
https://segmentfault.com/q/1010000022940925/a-1020000022948728 flink如何让非广播流后于广播流初始化后执行
https://www.jianshu.com/p/a09827b1d6da Flink中的广播流之BroadcastStream
https://blog.csdn.net/nazeniwaresakini/article/details/107404951 Flink广播流、广播状态原理简析
https://blog.csdn.net/qq_22222499/article/details/100044685 Flink 广播流最佳实践