无人机走航车秒数据，放开监听

lizijie

2021-09-03 8721fa31ed2ff48443acf07a688d4ed695a6170d

 screen-manage/src/main/java/com/moral/api/kafka/consumer/DeviceConsumer.java

@@ -47,7 +47,7 @@
    private HistorySecondUavService historySecondUavService;

    //分钟数据
    //@KafkaListener(topics = KafkaConstants.TOPIC_MINUTE, containerFactory = "insertListenerContainerFactory")
    @KafkaListener(topics = KafkaConstants.TOPIC_MINUTE, containerFactory = "insertListenerContainerFactory")
    public void listenMinute(ConsumerRecord<String, String> record, Acknowledgment ack) {
        String msg = record.value();
        try {
@@ -86,7 +86,7 @@
    }

    //小时数据
    //@KafkaListener(topics = KafkaConstants.TOPIC_HOUR, containerFactory = "insertListenerContainerFactory")
    @KafkaListener(topics = KafkaConstants.TOPIC_HOUR, containerFactory = "insertListenerContainerFactory")
    public void listenHour(ConsumerRecord<String, String> record, Acknowledgment ack) {
        String msg = record.value();
        try {
@@ -125,7 +125,7 @@
    }

    //秒数据，修改设备状态，缓存最新秒数据
    //@KafkaListener(topics = KafkaConstants.TOPIC_SECOND, containerFactory = "stateListenerContainerFactory")
    @KafkaListener(topics = KafkaConstants.TOPIC_SECOND, containerFactory = "stateListenerContainerFactory")
    public void listenSecond(ConsumerRecord<String, String> record) {
        String msg = record.value();
        try {