This is an automated email from the ASF dual-hosted git repository.
mikexue pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/eventmesh.git
The following commit(s) were added to refs/heads/master by this push:
new b42f7b408 [ISSUE # 4137]Replace printStackTrace with error logging in
RocketMQSinkConnector (#4188)
b42f7b408 is described below
commit b42f7b4082b2ed1cfe5f3de01bb1df46dd09923e
Author: ruhshan <[email protected]>
AuthorDate: Mon Jul 10 14:57:39 2023 +0600
[ISSUE # 4137]Replace printStackTrace with error logging in
RocketMQSinkConnector (#4188)
---
.../connector/rocketmq/sink/connector/RocketMQSinkConnector.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/eventmesh-connectors/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/sink/connector/RocketMQSinkConnector.java
b/eventmesh-connectors/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/sink/connector/RocketMQSinkConnector.java
index 2ac0a3052..f33e604e2 100644
---
a/eventmesh-connectors/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/sink/connector/RocketMQSinkConnector.java
+++
b/eventmesh-connectors/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/sink/connector/RocketMQSinkConnector.java
@@ -78,7 +78,7 @@ public class RocketMQSinkConnector implements Sink {
try {
SendResult sendResult = producer.send(message);
} catch (Exception e) {
- e.printStackTrace();
+ log.error("[RocketMQSinkConnector] sendResult has error : ",
e);
}
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
