Each message will be consumed twice.[Bug]

[mrcat2018]

What happened

Anytime it happens.

What you expected to happen

The confirmed message should not be consumed again.

How to reproduce

func main() {
cfg, err := config.ParseAddress("xxx")
if err != nil {
log.Errorf("Failed to parse address", err.Error())
panic(err)
}
c, err := client.NewConsumer(cfg)
if err != nil {
log.Errorf("new consumer error %s", err.Error())
panic(err)
}
start := time.Now()
for {
elapsed := time.Since(start)
if elapsed >= 10*time.Minute {
break
}
log.Debug("before GetMessage ")
crmsg, err := c.GetMessage()
if err != nil {
log.Errorf("Get message error %s", err.Error())
continue
}
cr, err := c.Confirm(crmsg.ConfirmContext, true)
if err != nil {
log.Errorf("Confirm error %s", err.Error())
continue
}
log.Debug(cr)
consume(context.Background(), crmsg)
}
c.Close()
}

Environment

centos7

InLong version

master

InLong Component

InLong TubeMQ

Are you willing to submit PR?

• Yes, I am willing to submit a PR!

Code of Conduct

• I agree to follow this project's Code of Conduct