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 a4e45b5..f768647 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
@@ -53,17 +53,23 @@ public class NameplateKafkaConsumer {
         log.info("nameplateKafkaConsumerMessage，消息：{}", recordMessages);
         if (StringUtils.isEmpty(recordMessages)) {
             ack.acknowledge();
-            log.info("nameplateKafkaConsumerMessage，消息为空");
+            log.info("nameplateKafkaConsumer为空");
             return;
         }
 
         try {
             NameplateTableKafkaDTO tmNameplateCorpus = JSON.parseObject(recordMessages, NameplateTableKafkaDTO.class);
-            if (!"INSERT".equals(tmNameplateCorpus.getType()) || CollectionUtils.isEmpty(tmNameplateCorpus.getData())) {
-                log.info("nameplateKafkaConsumerMessage，不满足条件");
+            if (!"INSERT".equals(tmNameplateCorpus.getType()) ) {
+                log.info("nameplateKafka不是INSERT");
+            }
+            if (CollectionUtils.isEmpty(tmNameplateCorpus.getData())) {
+                log.info("nameplateKafkagetData为空");
+                ack.acknowledge();
+                return;
             }
 
-
+            tmNameplateCorpus.getData().forEach(nameplate ->
+                    tmNameplateCorpusService.processItem(nameplate));
 
         } catch (Exception e) {
             log.error("处理消息失败", e);