| File was renamed from screen-manage/src/main/java/com/moral/api/kafka/consumer/KafkaConsumer.java |
| | |
|---|
| | | import com.moral.constant.RedisConstants; |
|---|
| | | |
|---|
| | | /* |
|---|
| | | * 设备数据接入 |
|---|
| | | * 普通设备消费者 |
|---|
| | | * */ |
|---|
| | | @Component |
|---|
| | | @Slf4j |
|---|
| | | public class KafkaConsumer { |
|---|
| | | public class DeviceConsumer { |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private HistoryMinutelyService historyMinutelyService; |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | //特殊设备秒数据 |
|---|
| | | @KafkaListener(topics = KafkaConstants.UAV_TOPIC_SECOND, groupId = KafkaConstants.GROUP_INSERT, containerFactory = "kafkaListenerContainerFactory") |
|---|
| | | @KafkaListener(topics = KafkaConstants.UAV_TOPIC_SECOND, groupId = KafkaConstants.GROUP_INSERT, containerFactory = "insertListenerContainerFactory") |
|---|
| | | public void listenSecondSpecial(ConsumerRecord<String, String> record, Acknowledgment ack) { |
|---|
| | | String msg = record.value(); |
|---|
| | | try { |
|---|
