apache / apache/rocketmq-client-cpp
why the “DefaultMQPullConsumer::persistConsumerOffset4PullConsumer“ can not be used？
Aperta
- Lingua principale
- C++
- Stelle
- 393
- Fork
- 167
- Metriche di merge delle PR
- Nessuna PR unita negli ultimi 30g
Descrizione
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
Guida per i contributori
Apri la guida per i contributori
Valutazione
Questa issue non è ancora stata valutata.