diff --git a/src/test/java/com/snowflake/kafka/connector/records/RecordContentTest.java b/src/test/java/com/snowflake/kafka/connector/records/RecordContentTest.java
index 822463b67..ed682d0f9 100644
--- a/src/test/java/com/snowflake/kafka/connector/records/RecordContentTest.java
+++ b/src/test/java/com/snowflake/kafka/connector/records/RecordContentTest.java
@@ -242,7 +242,7 @@ public void testSchematizationStringField() throws JsonProcessingException {
     SnowflakeJsonConverter jsonConverter = new SnowflakeJsonConverter();
 
     service.setEnableSchematization(true);
-    String value = "{\"name\":\"sf\",\"answer\":42}";
+    String value = "[{\"name\":\"sf\",\"answer\":42}]";
     byte[] valueContents = (value).getBytes(StandardCharsets.UTF_8);
     SchemaAndValue sv = jsonConverter.toConnectData(topic, valueContents);