apache / apache/rocketmq-client-cpp
why the “DefaultMQPullConsumer::persistConsumerOffset4PullConsumer“ can not be used?
- Linguagem predominante
- C++
- Estrelas
- 393
- Forks
- 167
- Métricas de merge de PRs
- Nenhum PR com merge em 30d
Descrição
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
Guia de contribuição
Direção de pesquisa
Start by locating DefaultMQPullConsumer::persistConsumerOffset4PullConsumer and inspect its callers, including the commented persistConsumerOffsetByResetOffset path. Determine how pull-consumer offsets are expected to persist across an application restart and whether repeated consumption is intended. Done means the supported behavior and required change or usage are clearly established.
Escrita pelo modelo de indexação a partir do texto da issue.
Avaliação
- Stack de tecnologia
- cpp
- Domínio
- distributed-systems
- Tipo de issue
- Bug
- Dificuldade
- 3/5
- Tempo estimado
- 1-2 dias
- Status de atividade
- Estagnada
- Clareza
- Precisa de esclarecimento
- Facilidade para iniciantes
- 25/100