diff --git a/plugins/common/mqtt/mqtt_v5.go b/plugins/common/mqtt/mqtt_v5.go index 47b020da8..4b112a7e1 100644 --- a/plugins/common/mqtt/mqtt_v5.go +++ b/plugins/common/mqtt/mqtt_v5.go @@ -97,7 +97,7 @@ func NewMQTTv5Client(cfg *MqttConfig) (*mqttv5Client, error) { options: opts, timeout: time.Duration(cfg.Timeout), username: cfg.Username, - password: config.Password, + password: cfg.Password, qos: cfg.QoS, retain: cfg.Retain, properties: properties,