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,8 @@ import com.moral.constant.KafkaConstants; import com.moral.constant.RedisConstants; /* * 普通设备消费者 * */ @Component @Slf4j public class DeviceConsumer { @@ -58,7 +58,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 +200,4 @@ } } } */