Test update schema definition

rozza · rozza · commit 1485eddcdd72 · 2020-09-15T13:32:14.000+01:00
diff --git a/src/integrationTest/java/com/mongodb/kafka/connect/source/MongoSourceTaskIntegrationTest.java b/src/integrationTest/java/com/mongodb/kafka/connect/source/MongoSourceTaskIntegrationTest.java
@@ -463,7 +463,7 @@ void testDeadletterQueueHandling() {
               put(
                   MongoSourceConfig.OUTPUT_SCHEMA_VALUE_CONFIG,
                   "{\"type\" : \"record\", \"name\" : \"fullDocument\","
-                      + "\"fields\" : [{\"name\": \"value\", \"type\": "
+                      + "\"fields\" : [{\"name\": \"_id\", \"type\": "
                       + "{\"type\" : \"array\", \"items\" : \"int\"}}]}");
             }
           };

Original file line number	Diff line number	Diff line change
`@@ -463,7 +463,7 @@ void testDeadletterQueueHandling() {`
`463`	`463`	`put(`
`464`	`464`	`MongoSourceConfig.OUTPUT_SCHEMA_VALUE_CONFIG,`
`465`	`465`	`"{\"type\" : \"record\", \"name\" : \"fullDocument\","`
`466`		`- + "\"fields\" : [{\"name\": \"value\", \"type\": "`
	`466`	`+ + "\"fields\" : [{\"name\": \"_id\", \"type\": "`
`467`	`467`	`+ "{\"type\" : \"array\", \"items\" : \"int\"}}]}");`
`468`	`468`	`}`
`469`	`469`	`};`