From 707d1b85d2443361d3cbc89e6d798a67b7a79b76 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=96=9C=E9=98=B3?= <terrance.lzm@alibaba-inc.com>
Date: Tue, 25 May 2021 22:13:45 +0800
Subject: [PATCH] [ISSUE #2708] Client may submit wrong offset when network
 instability, add more log

---
 .../client/impl/consumer/DefaultMQPushConsumerImpl.java         | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 e3db9a35..bb0b7f10 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
@@ -275,7 +275,7 @@ public class DefaultMQPushConsumerImpl implements MQConsumerInner {
                         offset = this.rebalanceImpl.computePullFromWhereWithException(pullRequest.getMessageQueue());
                     } catch (MQClientException e) {
                         this.executePullRequestLater(pullRequest, pullTimeDelayMillsWhenException);
-                        log.error("Failed to compute pull offset", e);
+                        log.error("Failed to compute pull offset, pullResult: {}", pullRequest, e);
                         return;
                     }
                     boolean brokerBusy = offset < pullRequest.getNextOffset();
-- 
GitLab