maixiaohai commented on issue #669: URL: https://github.com/apache/rocketmq-externals/issues/669#issuecomment-791513159
Hi, we have completed the code for storing the message to rocketmq broker, and will submit the producer part to the community next week. Regarding the consumption part, there is a question. 1) We use push consumers first to consume data, and found that data loss and duplication may occur during the process. 2) So we prefer to use pull consumers. The use of the pull mode requires synchronization and management of the offset, which has achieved the purpose of mqtt broker scalability. We tend to implement this process by writing metadata to a special topic. We hope to know what the community's opinion, or what better suggestions and tendencies there are. Thank you. ---------------------------------------------------------------- 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]
