diff --git a/internal/manager/eventbus/mqtt_client.go b/internal/manager/eventbus/mqtt_client.go index 6b77a679..ea62333d 100644 --- a/internal/manager/eventbus/mqtt_client.go +++ b/internal/manager/eventbus/mqtt_client.go @@ -99,7 +99,7 @@ func (m *MQTTForwarder) onConnectionUp(connMgr *autopaho.ConnectionManager, conn } func (m *MQTTForwarder) onConnectionError(err error) { - log.Warn().AnErr("cause", err).Msg("mqtt client: connection error") + log.Warn().AnErr("cause", err).Msg("mqtt client: could not connect to MQTT server") } func (m *MQTTForwarder) onClientError(err error) {