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 d3ecf50db4cdcb88f4eac89dca53c16d8869fa85..d095254a6f96637685bed9623e6d3cfddc4110d4 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 @@ -289,7 +289,7 @@ public class DefaultMQProducerImpl implements MQProducerInner { if (transactionCheckListener != null) { localTransactionState = transactionCheckListener.checkLocalTransactionState(message); } else if (transactionListener != null) { - log.info("Used new check API in transaction message"); + log.debug("Used new check API in transaction message"); localTransactionState = transactionListener.checkLocalTransaction(message); } else { log.warn("CheckTransactionState, pick transactionListener by group[{}] failed", group); @@ -1152,7 +1152,7 @@ public class DefaultMQProducerImpl implements MQProducerInner { if (null != localTransactionExecuter) { localTransactionState = localTransactionExecuter.executeLocalTransactionBranch(msg, arg); } else if (transactionListener != null) { - log.info("Used new transaction API"); + log.debug("Used new transaction API"); transactionListener.executeLocalTransaction(msg, arg); } if (null == localTransactionState) {