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());

Reply via email to