Fixed the non deterministic test testSerdeWithInputFormat

This commit is contained in:
Yug Vajani 2024-10-28 10:33:23 -05:00
parent 65acc86756
commit faf992987e
1 changed files with 17 additions and 11 deletions
extensions-core/kafka-indexing-service/src/test/java/org/apache/druid/indexing/kafka/supervisor

View File

@ -234,16 +234,22 @@ public class KafkaSupervisorSpecTest
+ " \"type\": \"kafka\",\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"
@ -281,7 +287,7 @@ public class KafkaSupervisorSpecTest
+ " \"fields\": []\n"
+ " },\n"
+ " \"featureSpec\": {}\n"
+ " },"
+ " },\n"
+ " \"consumerProperties\": {\n"
+ " \"bootstrap.servers\": \"localhost:9092\"\n"
+ " },\n"