mqtt: clarify connection error message for mqtt() source

Signed-off-by: Balazs Scheidler <[email protected]>
bazsi · Feb 8, 2024 · 765ca28 · 765ca28
1 parent 1202829
commit 765ca28
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/modules/mqtt/source/mqtt-source.c b/modules/mqtt/source/mqtt-source.c
@@ -138,7 +138,7 @@ _connect(LogThreadedFetcherDriver *s)
 
   if ((rc = MQTTClient_connect(self->client, &conn_opts)) != MQTTCLIENT_SUCCESS)
     {
-      msg_error("Error connecting mqtt client",
+      msg_error("Error connecting to mqtt server",
                 evt_tag_str("error_code", MQTTClient_strerror(rc)),
                 evt_tag_str("client_id", mqtt_client_options_get_client_id(&self->options)),
                 log_pipe_location_tag(&self->super.super.super.super.super));