apache / apache/rocketmq-client-cpp

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

未關閉
#370 0 則留言 0 個 reaction 已指派 0 人 在 GitHub 檢視
主要語言
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

把新 issue 寄到你的電子郵件信箱

精選適合新手參與的 GitHub issue 摘要。