apache / apache/rocketmq-client-cpp
why the “DefaultMQPullConsumer::persistConsumerOffset4PullConsumer“ can not be used？
Offen
- Vorherrschende Sprache
- C++
- Sterne
- 393
- Forks
- 167
- PR-Merge-Kennzahlen
- Keine gemergten PRs in 30 T.
Beschreibung
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
Beitragsleitfaden
Bewertung
Dieses Issue wurde noch nicht bewertet.