rocketmq-client-cpp
rocketmq-client-cpp copied to clipboard
why the “DefaultMQPullConsumer::persistConsumerOffset4PullConsumer“ can not be used?
void DefaultMQPullConsumer::persistConsumerOffset4PullConsumer(const MQMessageQueue& mq) { // impl->persistConsumerOffsetByResetOffset(mq); } this was comment out, After the application is restarted, how can I ensure no repeated consumption