fix request offset not changed in some case

apache · Jun 16, 2022 · fbce7c4 · fbce7c4
1 parent d86140d
commit fbce7c4
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/consumer/push_consumer.go b/consumer/push_consumer.go
@@ -757,6 +757,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)
@@ -766,8 +768,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 msgFounded != nil && len(msgFounded) != 0 {