From 5d15c3ed170f84bea092ee7d9418dd175cb00487 Mon Sep 17 00:00:00 2001
From: cserwen <cserwen@163.com>
Date: Sat, 15 Jan 2022 17:26:38 +0800
Subject: [PATCH] change the level to warn when the ack message failed (#3756)

---
 .../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 abe3ca75d1..87440ffdcf 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);