diff --git a/common/src/test/java/org/apache/rocketmq/common/compression/CompressionTypeTest.java b/common/src/test/java/org/apache/rocketmq/common/compression/CompressionTypeTest.java index faa4325be51..e0ec18fd44b 100644 --- a/common/src/test/java/org/apache/rocketmq/common/compression/CompressionTypeTest.java +++ b/common/src/test/java/org/apache/rocketmq/common/compression/CompressionTypeTest.java @@ -33,9 +33,9 @@ public void testCompressionTypeValues() { @Test public void testCompressionTypeOf() { - assertEquals(CompressionType.LZ4, CompressionType.of("LZ4"), "CompressionType.of(\"LZ4\") should return LZ4"); - assertEquals(CompressionType.ZSTD, CompressionType.of("ZSTD"), "CompressionType.of(\"ZSTD\") should return ZSTD"); - assertEquals(CompressionType.ZLIB, CompressionType.of("ZLIB"), "CompressionType.of(\"ZLIB\") should return ZLIB"); + assertEquals(CompressionType.LZ4, CompressionType.of("LZ4"), "CompressionType.of(LZ4) should return LZ4"); + assertEquals(CompressionType.ZSTD, CompressionType.of("ZSTD"), "CompressionType.of(ZSTD) should return ZSTD"); + assertEquals(CompressionType.ZLIB, CompressionType.of("ZLIB"), "CompressionType.of(ZLIB) should return ZLIB"); assertThrows(RuntimeException.class, () -> CompressionType.of("UNKNOWN"), "Unsupported compression type should throw RuntimeException"); }