This is an automated email from the ASF dual-hosted git repository. jinrongtong pushed a commit to branch develop in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/develop by this push: new 8f020b397a [ISSUE #7489] Code comment enhancement in example (#7490) 8f020b397a is described below commit 8f020b397a3afdd75429ae91e3624812b8ffc9e1 Author: Ao Qiao <qiao...@foxmail.com> AuthorDate: Mon Oct 23 16:34:10 2023 +0800 [ISSUE #7489] Code comment enhancement in example (#7490) * Doc: How to debug in Idea * en * enhance code comment --- .../src/main/java/org/apache/rocketmq/example/simple/PullConsumer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/example/src/main/java/org/apache/rocketmq/example/simple/PullConsumer.java b/example/src/main/java/org/apache/rocketmq/example/simple/PullConsumer.java index 5ac8d247d9..e1a02aa266 100644 --- a/example/src/main/java/org/apache/rocketmq/example/simple/PullConsumer.java +++ b/example/src/main/java/org/apache/rocketmq/example/simple/PullConsumer.java @@ -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());