fluyu edited a comment on issue #331: URL: https://github.com/apache/rocketmq-client-cpp/issues/331#issuecomment-678614597
> @ifplusor brokers can return the correct offset I think the premise for the brokers to give the correct offest is that messages already been commited. however `m_msgTreeMapTemp` is used to hold messages **being** consumed, they are **not commited** yet, so the exact `nextBeginOffset` is returned by the broker, which could exists in `m_msgTreeMapTemp`. I did observed no dup messges after applying the changes metioned above. ---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: [email protected]
