mirror of
https://github.com/apache/rocketmq.git
synced 2026-09-24 16:04:00 +08:00
[ISSUE #2708] Client may submit wrong offset when network instability, add more log
This commit is contained in:
+1
-1
@@ -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();
|
||||
|
||||
Reference in New Issue
Block a user