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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
