apache / apache/rocketmq-client-cpp

why the “DefaultMQPullConsumer::persistConsumerOffset4PullConsumer“ can not be used?

Aberta
#370 0 comentários 0 reações 0 responsáveis Ver no GitHub
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

Abrir o 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

Receba novas issues na sua caixa de entrada

Um resumo curto de issues do GitHub para quem está começando.