This is an automated email from the ASF dual-hosted git repository. jinrongtong pushed a commit to branch 5.0.0-alpha in repository https://gitbox.apache.org/repos/asf/rocketmq.git
commit 5d15c3ed170f84bea092ee7d9418dd175cb00487 Author: cserwen <[email protected]> AuthorDate: Sat Jan 15 17:26:38 2022 +0800 change the level to warn when the ack message failed (#3756) --- .../rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java index abe3ca7..87440ff 100644 --- a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java +++ b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java @@ -796,12 +796,12 @@ public class DefaultMQPushConsumerImpl implements MQConsumerInner { @Override public void onSuccess(AckResult ackResult) { if (ackResult != null && !AckStatus.OK.equals(ackResult.getStatus())) { - log.info("Ack message fail. ackResult: {}, extraInfo: {}", ackResult, extraInfo); + log.warn("Ack message fail. ackResult: {}, extraInfo: {}", ackResult, extraInfo); } } @Override public void onException(Throwable e) { - log.info("Ack message fail. extraInfo: {} error message: {}", extraInfo, e.toString()); + log.warn("Ack message fail. extraInfo: {} error message: {}", extraInfo, e.toString()); } }, requestHeader);
