From 0e8da5fe125a74d97595cc3d909f2bd37aeba3da Mon Sep 17 00:00:00 2001
From: Sudesh <swasnik@confluent.io>
Date: Sat, 13 Apr 2024 18:02:22 +0530
Subject: [PATCH] Reproduce : Schematization JsonNode incorrect Json

---
 .../snowflake/kafka/connector/records/RecordContentTest.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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);