~

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);

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