关闭mqtt重连

services/emqx-agent/client/mqtt_client.go

@@ -56,8 +56,8 @@ func initMqttClient(conf *MqttConfig) (mc MQTT.Client, err error) {
 		opts.AddBroker(broker)
 	}
 	opts.SetClientID(fmt.Sprintf("%s_%s", conf.ClientId, guid.S())).
-		SetUsername(conf.User).SetPassword(conf.Password).
-		SetConnectRetry(true)
+		SetUsername(conf.User).SetPassword(conf.Password)
+	//SetConnectRetry(true)
 	opts.SetConnectionAttemptHandler(func(broker *url.URL, tlsCfg *tls.Config) *tls.Config {
 		server.Log.Infof("connect to %s", broker.String())
 		return tlsCfg