cgeffect opened a new issue, #452: URL: https://github.com/apache/rocketmq-client-cpp/issues/452
When there is a large amount of message accumulation, the consumer's callback function will retrieve multiple messages at once, ranging from 1 to 32, but the maximum is 32 this function msgs param size is 1 <= msgs.size() <= 32 virtual rocketmq::ConsumeStatus consumeMessage(const std::vector<rocketmq::MQMessageExt> &msgs); This set of messages cannot have a separate status of CONSUME_SUCCESS or other status. So I must wait for all messages in this group to be processed by the business before being uniformly marked as CONSUME_SUCCESS or other status. I set consumer setConsumeMessageBatchMaxSize(1), but is not work. For example, if the size of msgs is 32, then I just need to return CONSUME_ SUCCESS means that all 32 messages will be consumed and removed from the message queue broker. Actually, I only want to consume one by one, rather than group by group But the same logic applies in the Java version of Rocketmq I can take one out of msgs and mark return CONSUME_ SUCCESS Other messages will continue to be sent and have not been removed from the broker. What should I do? -- 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]
