[I] [Bug] go pull consumer consume fail when storeType=defaultRocksDB [rocketmq]

[via GitHub]

yuz10 opened a new issue, #9146:
URL: https://github.com/apache/rocketmq/issues/9146

   ### Before Creating the Bug Report
   
   - [x] I found a bug, not just asking a question, which should be created in 
[GitHub Discussions](https://github.com/apache/rocketmq/discussions).
   
   - [x] I have searched the [GitHub 
Issues](https://github.com/apache/rocketmq/issues) and [GitHub 
Discussions](https://github.com/apache/rocketmq/discussions)  of this 
repository and believe that this is not a duplicate.
   
   - [x] I have confirmed that this bug belongs to the current repository, not 
other repositories of RocketMQ.
   
   
   ### Runtime platform environment
   
   ubuntu 24.04
   
   ### RocketMQ version
   
   5.3.1
   
   ### JDK Version
   
   1.8.0
   
   ### Describe the Bug
   
   go pull consumer consume fail when storeType=defaultRocksDB
   
   ### Steps to Reproduce
   
   1、set `storeType=defaultRocksDB` in broker.conf
   2、consume message with go pull consumer:
   ```go
   
   package main
   
   import (
        "context"
        "log"
        "time"
   
        "github.com/apache/rocketmq-client-go/v2"
   
        "github.com/apache/rocketmq-client-go/v2/rlog"
   
        "github.com/apache/rocketmq-client-go/v2/consumer"
        "github.com/apache/rocketmq-client-go/v2/primitive"
   )
   
   const (
        nameSrvAddr       = "127.0.0.1:8200"
        topic             = "test-topic"
        consumerGroupName = "testPullGroup"
        tag               = "*"
   )
   
   var pullConsumer rocketmq.PullConsumer
   var sleepTime = 1 * time.Second
   
   func main() {
        rlog.SetLogLevel("info")
        var nameSrv, err = primitive.NewNamesrvAddr(nameSrvAddr)
        if err != nil {
                log.Fatalf("NewNamesrvAddr err: %v", err)
        }
        pullConsumer, err = rocketmq.NewPullConsumer(
                consumer.WithGroupName(consumerGroupName),
                consumer.WithNameServer(nameSrv),
                consumer.WithMaxReconsumeTimes(2),
                //consumer.WithPullBatchSize(32),
        )
        if err != nil {
                log.Fatalf("fail to new pullConsumer: %v", err)
        }
        selector := consumer.MessageSelector{
                Type:       consumer.TAG,
                Expression: tag,
        }
        err = pullConsumer.Subscribe(topic, selector)
        if err != nil {
                log.Fatalf("fail to Subscribe: %v", err)
        }
        err = pullConsumer.Start()
        if err != nil {
                log.Fatalf("fail to Start: %v", err)
        }
   
        for {
                poll()
        }
   }
   
   func poll() {
        cr, err := pullConsumer.Poll(context.TODO(), time.Second*5)
        if consumer.IsNoNewMsgError(err) {
                return
        }
        if err != nil {
                log.Printf("[poll error] err=%v", err)
                time.Sleep(sleepTime)
                return
        }
        log.Println("msgList: ", cr.GetMsgList())
        log.Println("messageQueue: ", cr.GetMQ())
        log.Println("processQueue: ", cr.GetPQ())
        pullConsumer.ACK(context.TODO(), cr, consumer.ConsumeSuccess)
   }
   ```
   
   ### What Did You Expect to See?
   
   expect consume success
   
   ### What Did You See Instead?
   
   consume fail with message: 
   consumer request topic: test-topic, offset: 0, minOffset: 0, maxOffset: 1, 
but access logic queue failed. Correct nextBeginOffset to 0
   
   I found the maxMsgNums is 0 in pull request:
   ```
   request:
   
{"code":11,"language":"GO","version":317,"opaque":976,"flag":0,"remark":"","extFields":{"consumerGroup":"testPullGroup","queueId":"1","maxMsgNums":"0","sysFlag":"6","subscription":"*","expressionType":"TAG","bname":"broker-0","topic":"test-topic","queueOffset":"0","commitOffset":"0","suspendTimeoutMillis":"20000","subVersion":"0"}}
   response:
   
{"code":19,"extFields":{"suggestWhichBrokerId":"0","groupSysFlag":"0","msgCount4Commercial":"0","TRACE_ON":"true","nextBeginOffset":"0","MSG_REGION":"","maxOffset":"26","minOffset":"0","topicSysFlag":"0"},"flag":1,"language":"JAVA","opaque":976,"remark":"OFFSET_FOUND_NULL","serializeTypeCurrentRPC":"JSON","version":475}
   ```
   
   ### Additional Context
   
   the default pullBatchSize of go pull consumer is 0, but works fine with 
default consume queue. 


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscr...@rocketmq.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org