40岁程序员学Flink,对接kafka

一,背景 公司需要用到flink和kafka来处理大数据,对于一个没有接触过这两个东西的40岁程序员,决定自学一下,用了两天的时间终于实现了flink和kafka的对接,目标就是要向kafka输入 "时间戳,温度,设备ID",然后在flink里面按照时间戳分组,再按照设备ID计算的在一个时间段内的温度平均值。   二,运行环境 window 10, kafka 2.1.1, flink 1.7.2
相关文章
相关标签/搜索