sunjianlin12345 opened a new issue #298:
URL: https://github.com/apache/rocketmq-spring/issues/298
当网络或其它异常情况时，mq重试16次，且当MessageExt中的body消息信息内容较大时，下述2个位置的代码打印了大量的日志：
org.apache.rocketmq.spring.support.DefaultRocketMQListenerContainer.DefaultMessageListenerConcurrently#consumeMessage
org.apache.rocketmq.spring.support.DefaultRocketMQListenerContainer.DefaultMessageListenerOrderly#consumeMessage
这段代码打印了大量日志，导致日志文件特别大，希望这个能优化下：
log.warn("consume message failed. messageExt:{}", messageExt, e);
`try {
long now = System.currentTimeMillis();
rocketMQListener.onMessage(doConvertMessage(messageExt));
long costTime = System.currentTimeMillis() - now;
log.info("consume {} cost: {} ms",
messageExt.getMsgId(), costTime);
} catch (Exception e) {
log.warn("consume message failed. messageExt:{}",
messageExt, e);
context.setSuspendCurrentQueueTimeMillis(suspendCurrentQueueTimeMillis);
return
ConsumeOrderlyStatus.SUSPEND_CURRENT_QUEUE_A_MOMENT;
}`
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
[email protected]
