apache / apache/rocketmq-client-cpp
why the “DefaultMQPullConsumer::persistConsumerOffset4PullConsumer“ can not be used?
未關閉
- 主要語言
- C++
- 星號
- 393
- 分支
- 167
- PR 合併指標
- 30 天內沒有已合併 PR
描述
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
貢獻指南
研究方向
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.
由索引模型根據 Issue 內容生成。
評估
- 技術堆疊
- cpp
- 領域
- distributed-systems
- Issue 類型
- 缺陷
- 難度
- 3/5
- 預估耗時
- 1-2 天
- 活躍度
- 停滯
- 描述清晰度
- 需要釐清
- 新手友好度
- 25/100