diff --git a/extensions-core/kafka-indexing-service/src/test/java/org/apache/druid/indexing/kafka/supervisor/KafkaSupervisorSpecTest.java b/extensions-core/kafka-indexing-service/src/test/java/org/apache/druid/indexing/kafka/supervisor/KafkaSupervisorSpecTest.java
index f8feeae9be7..9428d27b871 100644
--- a/extensions-core/kafka-indexing-service/src/test/java/org/apache/druid/indexing/kafka/supervisor/KafkaSupervisorSpecTest.java
+++ b/extensions-core/kafka-indexing-service/src/test/java/org/apache/druid/indexing/kafka/supervisor/KafkaSupervisorSpecTest.java
@@ -409,16 +409,22 @@ public class KafkaSupervisorSpecTest
                   + "  \"spec\": {\n"
                   + "  \"dataSchema\": {\n"
                   + "    \"dataSource\": \"metrics-kafka\",\n"
-                  + "    \"timestampSpec\": {\n"
-                  + "      \"column\": \"timestamp\",\n"
-                  + "      \"format\": \"auto\"\n"
-                  + "    },\n"
-                  + "    \"dimensionsSpec\": {\n"
-                  + "      \"dimensions\": [],\n"
-                  + "      \"dimensionExclusions\": [\n"
-                  + "        \"timestamp\",\n"
-                  + "        \"value\"\n"
-                  + "      ]\n"
+                  + "    \"parser\": {\n"
+                  + "      \"type\": \"string\",\n"
+                  + "      \"parseSpec\": {\n"
+                  + "        \"format\": \"json\",\n"
+                  + "        \"timestampSpec\": {\n"
+                  + "          \"column\": \"timestamp\",\n"
+                  + "          \"format\": \"auto\"\n"
+                  + "        },\n"
+                  + "        \"dimensionsSpec\": {\n"
+                  + "          \"dimensions\": [],\n"
+                  + "          \"dimensionExclusions\": [\n"
+                  + "            \"timestamp\",\n"
+                  + "            \"value\"\n"
+                  + "          ]\n"
+                  + "        }\n"
+                  + "      }\n"
                   + "    },\n"
                   + "    \"metricsSpec\": [\n"
                   + "      {\n"
@@ -456,7 +462,7 @@ public class KafkaSupervisorSpecTest
                   + "        \"fields\": []\n"
                   + "      },\n"
                   + "      \"featureSpec\": {}\n"
-                  + "    },"
+                  + "    },\n"
                   + "    \"consumerProperties\": {\n"
                   + "      \"bootstrap.servers\": \"localhost:9092\"\n"
                   + "    },\n"