Add debug logs to test3ConsumerAndCrashOne for investigating CI failure

chi3316 · Sep 7, 2024 · a0d33dc · a0d33dc
1 parent a8dc90e
commit a0d33dc
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 0 deletions.
diff --git a/pom.xml b/pom.xml
@@ -506,6 +506,9 @@
                             <excludes>
                                 <exclude>**/NormalMsgDelayIT.java</exclude>
                             </excludes>
+                            <includes>
+                                <include>**/NormalMsgDynamicBalanceIT.java</include>
+                            </includes>
                         </configuration>
                         <executions>
                             <execution>

diff --git a/...test/java/org/apache/rocketmq/test/client/consumer/balance/NormalMsgDynamicBalanceIT.java b/...test/java/org/apache/rocketmq/test/client/consumer/balance/NormalMsgDynamicBalanceIT.java
@@ -108,6 +108,8 @@ public void test3ConsumerAndCrashOne() throws InterruptedException {
             consumer1.getListener(), consumer2.getListener());
         assertThat(recvAll).isEqualTo(true);
 
+        logger.error("Consumer1 received: " + consumer1.getListener().getAllUndupMsgBody().size());
+        logger.error("Consumer2 received: " + consumer2.getListener().getAllUndupMsgBody().size());
         boolean balance = VerifyUtils.verifyBalance(msgSize,
             VerifyUtils.getFilterdMessage(producer.getAllMsgBody(),
                 consumer1.getListener().getAllUndupMsgBody()).size(),