search

apache / rocketmq-client-go

Apache RocketMQ go client
https://rocketmq.apache.org/
Apache License 2.0
1.3k stars 419 forks source link

consumer shutdown will result in unspent mark consumption success #1120

Open zc24 opened 9 months ago

zc24 commented 9 months ago

if consumer all return ConsumeRetryLater, when consumer run consumer.shutdown. View message trace The message was successfully consumed

err = cs.Subscribe("topic", selector, func(ctx context.Context, ext ...*primitive.MessageExt) (consumer.ConsumeResult, error) { for i := range ext { fmt.Printf("%+v\n", ext[i]) } return consumer.ConsumeRetryLater, nil }) if err != nil { fmt.Println(err) }