screen-manage/src/main/java/com/moral/api/kafka/consumer/DeviceConsumer.java
@@ -1,3 +1,4 @@ /* package com.moral.api.kafka.consumer; import com.moral.api.service.*; @@ -18,9 +19,11 @@ import com.moral.constant.KafkaConstants; import com.moral.constant.RedisConstants; */ /* * 普通设备消费者 * */ * *//* @Component @Slf4j public class DeviceConsumer { @@ -58,7 +61,7 @@ } //数据过滤 data.remove("time"); // data.remove("time"); data.remove("entryTime"); Iterator<Map.Entry<String, Object>> iterator = data.entrySet().iterator(); Map<String, Object> newMap = new HashMap<>(); @@ -200,3 +203,4 @@ } } } */