search

apache / rocketmq-client-go

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

[FATAL] consumeMessageCurrently miss consumption #976

Closed wysobj closed 1 year ago

wysobj commented 1 year ago

In consumeMessageCurrently, when the consumer fails to consume messages, these messages are sent back to RETRY Topic. But in the case of sending back those messages failed, the offset of the queue is STILL updated by those messages. Eventually these messages are not in the retry topic, and the offset skip them behind, which means these messages will never been consumed again. image

wysobj commented 1 year ago

found same closed issue：https://github.com/apache/rocketmq-client-go/pull/860