|  |  |  | 
|---|
|  |  |  | /* | 
|---|
|  |  |  | package com.moral.api.kafka.consumer; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | import com.moral.api.service.*; | 
|---|
|  |  |  | 
|---|
|  |  |  | 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<>(); | 
|---|
|  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | */ | 
|---|