GitHub user cserwen added a comment to the discussion: [Bug] the queue's 
messages, span too long, so do flow control

It should be caused by this problem  
https://github.com/apache/rocketmq/pull/3861

As for the reason for throwing an exception, it may be that 
`PROPERTY_CONSUME_START_TIMESTAMP` has not been set when cleaning up the 
expired message, so an exception is thrown at here.
https://github.com/apache/rocketmq/blob/9f95a972e10e0681bc3f2d00e9957aa212e897b5/client/src/main/java/org/apache/rocketmq/client/impl/consumer/ProcessQueue.java#L88C1-L89C1

GitHub link: 
https://github.com/apache/rocketmq/discussions/7133#discussioncomment-6717708

----
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org

Reply via email to