大数据体系

Flink同一个DataStream同时供多个业务使用

一：背景我们项目中用到Flink的Java客户端 用来做数据处理数据源：kafka发送源：kafka原来只有一个业务需求，可以理解为对mq消息中的一个字段做累计和。现在又多了两个业务需求，可以理解为对mq消息的其他字段做累加和。此时面临的问题是：flink 做完类似于 map filter k...
2022-01-27 14:23 阅读数 72
技术
下载桌面版
GitHub
百度网盘（提取码：draw）
Gitee
云服务器优惠
阿里云优惠券
腾讯云优惠券
华为云优惠券
站点信息
问题反馈
邮箱：[email protected]
QQ群：766591547
关注微信
©2020-2024 ioDraw All rights reserved, Privacy Policy