diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/NameplateKafkaConsumer.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/NameplateKafkaConsumer.java index 445dc0c..a8787be 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/NameplateKafkaConsumer.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/NameplateKafkaConsumer.java @@ -65,7 +65,7 @@ public class NameplateKafkaConsumer { if (CollectionUtils.isEmpty(tmNameplateCorpus.getData())) { log.info("nameplateKafkagetData为空"); ack.acknowledge(); - return; + }//去掉业务调用 } catch (Exception e) { log.error("处理消息失败", e);