优化自动提交代码

makemyownlife · Apr 17, 2024 · 1c07f5f · 1c07f5f
1 parent 760b861
commit 1c07f5f
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...nt/src/test/java/org/apache/rocketmq/client/consumer/DefaultLitePullConsumerUnitTest.java b/...nt/src/test/java/org/apache/rocketmq/client/consumer/DefaultLitePullConsumerUnitTest.java
@@ -62,9 +62,11 @@ public void testNoAutoCommit() throws MQClientException {
                     for (MessageExt messageExt : messageExts) {
                         // 打印消息内存
                         System.out.println(new String(first.getBody()));
+                        // 业务处理代码
                     }
+                   litePullConsumer.commitSync();
                     // 回滚到第一条消息的点位
-                    litePullConsumer.seek(messageQueue, first.getQueueOffset());
+                 //   litePullConsumer.seek(messageQueue, first.getQueueOffset());
                 }
                 Thread.sleep(5000);
             }