[I] consumer shutdown will result in unspent mark consumption success [rocketmq-client-go]

[via GitHub]

zc24 opened a new issue, #1120:
URL: https://github.com/apache/rocketmq-client-go/issues/1120

   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)
        }`


-- 
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