[rocketmq] branch develop updated: [ISSUE #5152] Change the error log level to error (#5153)

[lizhanhui]

This is an automated email from the ASF dual-hosted git repository.

lizhanhui pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new 198f786ee [ISSUE #5152] Change the error log level to error (#5153)
198f786ee is described below

commit 198f786ee3bd43e444bc6d908e3c4800d11ef739
Author: Oliver <wqdyx...@163.com>
AuthorDate: Wed Sep 28 14:25:50 2022 +0800

    [ISSUE #5152] Change the error log level to error (#5153)
---
 .../rocketmq/client/impl/producer/DefaultMQProducerImpl.java      | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java
 
b/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java
index 842853c48..89c549944 100644
--- 
a/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java
+++ 
b/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java
@@ -1326,12 +1326,12 @@ public class DefaultMQProducerImpl implements 
MQProducerInner {
                     }
 
                     if (localTransactionState != 
LocalTransactionState.COMMIT_MESSAGE) {
-                        log.info("executeLocalTransactionBranch return {}", 
localTransactionState);
-                        log.info(msg.toString());
+                        log.info("executeLocalTransactionBranch return: {} 
messageTopic: {} transactionId: {} tag: {} key: {}",
+                            localTransactionState, msg.getTopic(), 
msg.getTransactionId(), msg.getTags(), msg.getKeys());
                     }
                 } catch (Throwable e) {
-                    log.info("executeLocalTransactionBranch exception", e);
-                    log.info(msg.toString());
+                    log.error("executeLocalTransactionBranch exception, 
messageTopic: {} transactionId: {} tag: {} key: {}",
+                        msg.getTopic(), msg.getTransactionId(), msg.getTags(), 
msg.getKeys(), e);
                     localException = e;
                 }
             }