apache / apache/rocketmq-client-cpp
why the “DefaultMQPullConsumer::persistConsumerOffset4PullConsumer“ can not be used？
Ouverte
- Langage dominant
- C++
- Étoiles
- 393
- Forks
- 167
- Métriques de merge des PR
- Aucune PR mergée en 30 j
Description
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
Guide de contribution
Ouvrir le guide de contribution
Évaluation
Cette issue n'a pas encore été évaluée.