| | |
| | | import com.moral.constant.KafkaConstants; |
| | | import com.moral.constant.RedisConstants; |
| | | |
| | | /* |
| | | * 普通设备消费者 |
| | | * */ |
| | | |
| | | |
| | | @Component |
| | | @Slf4j |
| | | public class DeviceConsumer { |
| | |
| | | } |
| | | |
| | | //数据过滤 |
| | | data.remove("time"); |
| | | // data.remove("time"); |
| | | data.remove("entryTime"); |
| | | Iterator<Map.Entry<String, Object>> iterator = data.entrySet().iterator(); |
| | | Map<String, Object> newMap = new HashMap<>(); |
| | |
| | | } |
| | | |
| | | //数据过滤 |
| | | data.remove("time"); |
| | | // data.remove("time"); |
| | | data.remove("entryTime"); |
| | | Iterator<Map.Entry<String, Object>> iterator = data.entrySet().iterator(); |
| | | Map<String, Object> newMap = new HashMap<>(); |