cserwen opened a new issue, #4606: URL: https://github.com/apache/rocketmq/issues/4606
**BUG REPORT** 1. Please describe the issue you observed: Trace message are built when PullTaskImpl finishes executing. https://github.com/apache/rocketmq/blob/b136f9bb6725867dcc5d00798addd0de7382ffb3/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultLitePullConsumerImpl.java#L952 But in fact the message is only stored in the local cache, and only when `poll()` is called, the user's program will actually consume the messages, so I think the traces message should be built in `poll()` https://github.com/apache/rocketmq/blob/b136f9bb6725867dcc5d00798addd0de7382ffb3/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultLitePullConsumerImpl.java#L542 Will there be any problem with the implementation here? @zhangjidi2016 -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
