forked from moral

parent: 1d242e90 | patch | commit | ignore whitespace
lizijie
2022-08-15 00a4d1eb8a4b3eac353a291daf9b0c5ebda8c01c 
走航车数据删掉groupId
1 files modified
2 ■■■■■ changed files
screen-manage/src/main/java/com/moral/api/kafka/consumer/DeviceConsumer.java 2 ●●●●● patch | view | raw | blame | history 
 screen-manage/src/main/java/com/moral/api/kafka/consumer/DeviceConsumer.java


@@ -176,7 +176,7 @@


    }




    //走航车秒数据


    @KafkaListener(topics = KafkaConstants.CRUISER_TOPIC_SECOND, groupId = KafkaConstants.GROUP_INSERT, containerFactory = "insertListenerContainerFactory")


    @KafkaListener(topics = KafkaConstants.CRUISER_TOPIC_SECOND, containerFactory = "insertListenerContainerFactory")


    public void listenSecondCruiser(ConsumerRecord<String, String> record, Acknowledgment ack) {


        String msg = record.value();


        try {