[rocketmq] branch 5.0.0-alpha updated: change the level to warn when the ack message failed (#3756)

[duhengforever]

This is an automated email from the ASF dual-hosted git repository.

duhengforever pushed a commit to branch 5.0.0-alpha
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/5.0.0-alpha by this push:
     new 1b09702  change the level to warn when the ack message failed (#3756)
1b09702 is described below

commit 1b097024a755b696c3cca667993cbcea29a2a4b9
Author: cserwen <cser...@163.com>
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);