From 2c35e13f5e7cbb5e4f13393285aa16ab095bfc23 Mon Sep 17 00:00:00 2001 From: xiejiashuai <707094980@qq.com> Date: Tue, 13 Aug 2019 10:07:16 +0800 Subject: [PATCH] update orderly message log level to info --- .../rocketmq/consuming/RocketMQListenerBindingContainer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/spring-cloud-stream-binder-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/consuming/RocketMQListenerBindingContainer.java b/spring-cloud-stream-binder-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/consuming/RocketMQListenerBindingContainer.java index 22834af2b..5bf540e07 100644 --- a/spring-cloud-stream-binder-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/consuming/RocketMQListenerBindingContainer.java +++ b/spring-cloud-stream-binder-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/consuming/RocketMQListenerBindingContainer.java @@ -408,7 +408,7 @@ public class RocketMQListenerBindingContainer long now = System.currentTimeMillis(); rocketMQListener.onMessage(convertToSpringMessage(messageExt)); long costTime = System.currentTimeMillis() - now; - log.debug("consume {} message key:[{}] cost: {} ms", + log.info("consume {} message key:[{}] cost: {} ms", messageExt.getMsgId(), messageExt.getKeys(), costTime); } catch (Exception e) {