diff --git a/cloud-modules/cloud-modules-parsing/src/main/java/com/muyu/parsing/mqtt/MqttTest.java b/cloud-modules/cloud-modules-parsing/src/main/java/com/muyu/parsing/mqtt/MqttTest.java
index ece270c..43dd7d8 100644
--- a/cloud-modules/cloud-modules-parsing/src/main/java/com/muyu/parsing/mqtt/MqttTest.java
+++ b/cloud-modules/cloud-modules-parsing/src/main/java/com/muyu/parsing/mqtt/MqttTest.java
@@ -87,15 +87,15 @@ public class MqttTest {
                                 .key(carMessage.getMessageTypeCode())
                                 .label(carMessage.getMessageTypeCode())
                                 .value(value)
-                                .type("String")
-                                .build());
-                        kafKaDataList.add(KafKaData.builder()
-                                .key("firmCode")
-                                .label("企业编码")
-                                .value("firm01")
-                                .type("String")
+                                .type(carMessage.getMessageType())
                                 .build());
                     }
+                    kafKaDataList.add(KafKaData.builder()
+                            .key("firmCode")
+                            .label("企业编码")
+                            .value("firm01")
+                            .type("String")
+                            .build());
                     String jsonString = JSONObject.toJSONString(kafKaDataList);
 
                     ProducerRecord<String, String> producerRecord = new ProducerRecord<>(KafkaConstants.KafkaTopic, jsonString);
@@ -108,7 +108,6 @@ public class MqttTest {
                 }
 
 
-
                 // 接收信息
                 @Override
                 public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) {