2、开发超岗脱岗算法开发 3、传输kafka数据添加字段
# Conflicts: # src/main/java/com/censoft/flink/StreamingJob.java
2、修改监听mqtt频道前缀
