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 c8a514b..e2df8b6 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
@@ -1,7 +1,6 @@
 package com.muyu.parsing.mqtt;
 
 import com.alibaba.fastjson2.JSONObject;
-import com.muyu.common.core.domain.Result;
 import com.muyu.common.kafka.constants.KafkaConstants;
 import com.muyu.parsing.domain.KafKaData;
 import com.muyu.parsing.domain.SysCarMessage;
@@ -15,9 +14,7 @@ import org.springframework.stereotype.Component;
 import javax.annotation.PostConstruct;
 import javax.annotation.Resource;
 import java.util.ArrayList;
-import java.util.HashMap;
 import java.util.List;
-import java.util.concurrent.CompletableFuture;
 
 
 /**
@@ -70,7 +67,7 @@ public class MqttTest {
                     log.info(new String(mqttMessage.getPayload()));
                     List<KafKaData> kafKaDataList = new ArrayList<>();
                     String[] test = string.split(" ");
-                    String[] results = new String[list.size()];
+//                    String[] results = new String[list.size()];
                     for (SysCarMessage carMessage : list) {
                         int start = Integer.parseInt(carMessage.getMessageStartIndex()) - 1;
                         int end = Integer.parseInt(carMessage.getMessageEndIndex());