diff --git a/src/main/java/com/iflytop/digester/DigestionTaskTheadManager.java b/src/main/java/com/iflytop/digester/DigestionTaskTheadManager.java
index fdbeab3..31691fc 100644
--- a/src/main/java/com/iflytop/digester/DigestionTaskTheadManager.java
+++ b/src/main/java/com/iflytop/digester/DigestionTaskTheadManager.java
@@ -68,8 +68,8 @@ public class DigestionTaskTheadManager {
         });
         try {
             MqttConnectOptions options = new MqttConnectOptions();
-            options.setUserName(this.mqttBrokerUsername);
-            options.setPassword(this.mqttBrokerPassword.toCharArray());
+//            options.setUserName(this.mqttBrokerUsername);
+//            options.setPassword(this.mqttBrokerPassword.toCharArray());
             client.connect(options);
         } catch (MqttException e) {
             throw new RuntimeException(e);
diff --git a/src/main/resources/application-dev.yml b/src/main/resources/application-dev.yml
index 06258ed..4004e56 100644
--- a/src/main/resources/application-dev.yml
+++ b/src/main/resources/application-dev.yml
@@ -25,7 +25,7 @@ device:
       port: 20000
 
 mqtt-broker:
-  uri: tcp://broker.emqx.io:1883
+  uri: mqtt://192.168.8.10:1883
   username: admin
   password: public
   clientId: digester