fix request offset not changed in some case (#844)

Co-authored-by: dengzhiwen1 <[email protected]>
apache · Jul 21, 2022 · a05a720 · a05a720
1 parent ad827de
commit a05a720
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/consumer/push_consumer.go b/consumer/push_consumer.go
@@ -770,6 +770,8 @@ func (pc *pushConsumer) pullMessage(request *PullRequest) {
  goto NEXT
  }
 
+ pc.processPullResult(request.mq, result, sd)
+
  switch result.Status {
  case primitive.PullFound:
  rlog.Debug(fmt.Sprintf("Topic: %s, QueueId: %d found messages.", request.mq.Topic, request.mq.QueueId), nil)
@@ -779,8 +781,6 @@ func (pc *pushConsumer) pullMessage(request *PullRequest) {
  rt := time.Now().Sub(beginTime) / time.Millisecond
  pc.stat.increasePullRT(pc.consumerGroup, request.mq.Topic, int64(rt))
 
- pc.processPullResult(request.mq, result, sd)
-
  msgFounded := result.GetMessageExts()
  firstMsgOffset := int64(math.MaxInt64)
  if len(msgFounded) != 0 {