mirror of
https://github.com/apache/rocketmq.git
synced 2026-08-28 20:09:14 +08:00
* Doc: How to debug in Idea * en * enhance code comment
This commit is contained in:
@@ -75,7 +75,7 @@ public class PullConsumer {
|
||||
|
||||
if (msgs != null && !msgs.isEmpty()) {
|
||||
this.doSomething(msgs);
|
||||
//update offset to broker
|
||||
//update offset to local memory, eventually to broker
|
||||
consumer.updateConsumeOffset(messageQueue, pullResult.getNextBeginOffset());
|
||||
//print pull tps
|
||||
this.incPullTPS(topic, pullResult.getMsgFoundList().size());
|
||||
|
||||
Reference in New Issue
Block a user