diff --git a/pulsar-io/mongo/src/test/java/org/apache/pulsar/io/mongodb/MongoSourceTest.java b/pulsar-io/mongo/src/test/java/org/apache/pulsar/io/mongodb/MongoSourceTest.java
index 7243b365e88a5..79b6fb4897301 100644
--- a/pulsar-io/mongo/src/test/java/org/apache/pulsar/io/mongodb/MongoSourceTest.java
+++ b/pulsar-io/mongo/src/test/java/org/apache/pulsar/io/mongodb/MongoSourceTest.java
@@ -128,9 +128,13 @@ public void testWriteBadMessage() throws Exception {
 
         Record<byte[]> record = source.read();
 
-        assertEquals(new String(record.getValue()),
-                "{\"fullDocument\":{\"hello\":\"pulsar\"},"
+        String value = new String(record.getValue());
+        String expected = "{\"fullDocument\":{\"hello\":\"pulsar\"},"
                 + "\"ns\":{\"databaseName\":\"hello\",\"collectionName\":\"pulsar\",\"fullName\":\"hello.pulsar\"},"
-                + "\"operation\":\"INSERT\"}");
+                + "\"operation\":\"INSERT\"}";
+        assertEquals(
+                Document.parse(value),
+                Document.parse(expected)
+        );
     }
 }