diff --git a/cloud-modules/cloud-modules-protocol-analysis/src/main/java/com/muyu/analysis/parsing/MQTT/ParsingMQTT.java b/cloud-modules/cloud-modules-protocol-analysis/src/main/java/com/muyu/analysis/parsing/MQTT/ParsingMQTT.java
index f6d51ca..80d1806 100644
--- a/cloud-modules/cloud-modules-protocol-analysis/src/main/java/com/muyu/analysis/parsing/MQTT/ParsingMQTT.java
+++ b/cloud-modules/cloud-modules-protocol-analysis/src/main/java/com/muyu/analysis/parsing/MQTT/ParsingMQTT.java
@@ -15,7 +15,6 @@ import lombok.extern.log4j.Log4j2;
 import org.apache.kafka.clients.producer.KafkaProducer;
 import org.apache.kafka.clients.producer.ProducerRecord;
 import org.eclipse.paho.client.mqttv3.*;
-import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.stereotype.Component;
 
@@ -59,7 +58,7 @@ public class ParsingMQTT {
             MqttClient sampleClient = new MqttClient(MQTTConnect.BROKER, MQTTConnect.CLIENT_ID);
             MqttConnectOptions connOpts = new MqttConnectOptions();
             connOpts.setCleanSession(true);
-            log.info("Connecting to MQTTConnect.BROKER: {}", MQTTConnect.BROKER);
+            log.info("连接中MQTTConnect.BROKER: {}", MQTTConnect.BROKER);
             sampleClient.connect(connOpts);
             sampleClient.subscribe(MQTTConnect.TOPIC, 0);
             sampleClient.setCallback(new MqttCallback() {
@@ -78,7 +77,7 @@ public class ParsingMQTT {
                     ProducerRecord<String, String> producerRecord = new ProducerRecord<>(KafkaConstants.MESSAGE_PARSING,
                             entries.toString()      );
                     kafkaProducer.send(producerRecord);
-                    log.info("解析之后的数据"+entries);
+                    log.info("解析之后的数据："+entries);
 
                 }