[GitHub] [inlong] healchow commented on a diff in pull request #7420: [INLONG-7419][Agent] Fix error of MQTT connector

["healchow (via GitHub)" <gi...@apache.org>]

healchow commented on code in PR #7420:
URL: https://github.com/apache/inlong/pull/7420#discussion_r1117884236


##########
inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/reader/MqttReader.java:
##########
@@ -116,8 +119,8 @@ private void connect() {
 
                     @Override
                     public void connectionLost(Throwable cause) {
-                        LOGGER.info("the mqtt connection is lost, try to reconnect. jobId:{},serverURI:{},clientId:{}",
-                                instanceId, serverURI, clientId);
+                        LOGGER.error("the mqtt jobId:{}, serverURI:{}, connection lost, {} ", instanceId,
+                                serverURI, cause.getMessage());

Review Comment:
   Do we need to print all stacks of the exception? Maybe using `cause` instead of `cause.getMessage()` is better if required.



-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@inlong.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org