integration test debug

apache · Sep 30, 2024 · f083373 · f083373
1 parent c99ff27
commit f083373
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/test/src/test/java/org/apache/rocketmq/test/client/producer/batch/BatchSendIT.java b/test/src/test/java/org/apache/rocketmq/test/client/producer/batch/BatchSendIT.java
@@ -266,8 +266,12 @@ public void testBatchSend_CompressionBody() throws Exception {
                 Assert.assertEquals(i + startOffset, messageExt.getQueueOffset());
                 Assert.assertEquals(batchTopic, messageExt.getTopic());
                 Assert.assertEquals(messageQueue.getQueueId(), messageExt.getQueueId());
+                if(bodyLen!=messageExt.getBody().length){
+                    logger.error("decompress fail? {} {}",i,messageExt);
+                }
                 Assert.assertEquals(bodyLen, messageExt.getBody().length);
                 Assert.assertTrue((messageExt.getSysFlag() & MessageSysFlag.COMPRESSED_FLAG) != 0);
+                Assert.assertTrue(messageExt.getStoreSize()<bodyLen);
             }
         }
     }