diff --git a/spring-cloud-alibaba-starters/spring-cloud-starter-stream-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/integration/outbound/RocketMQProducerMessageHandler.java b/spring-cloud-alibaba-starters/spring-cloud-starter-stream-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/integration/outbound/RocketMQProducerMessageHandler.java index 35450cb1c..c304d80f9 100644 --- a/spring-cloud-alibaba-starters/spring-cloud-starter-stream-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/integration/outbound/RocketMQProducerMessageHandler.java +++ b/spring-cloud-alibaba-starters/spring-cloud-starter-stream-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/integration/outbound/RocketMQProducerMessageHandler.java @@ -184,8 +184,10 @@ public class RocketMQProducerMessageHandler extends AbstractMessageHandler sendResult = this.send(mqMessage, this.messageQueueSelector, message.getHeaders(), message); } - log.info("the message has sent,message={},sendResult={}", mqMessage, - sendResult); + if(log.isDebugEnabled()) { + log.debug("the message has sent,message={},sendResult={}", mqMessage, + sendResult); + } if (sendResult == null || !SendStatus.SEND_OK.equals(sendResult.getSendStatus())) { log.error("message send fail.SendStatus is not OK.the message={}",