KAFKA-12800: Configure generator to fail on trailing JSON tokens (#10717)

cursedquail · web-flow · commit 63b6db39b55e · 2021-05-25T15:12:48.000+02:00
Reviewers: David Jacot &lt;djacot@confluent.io&gt;
diff --git a/generator/src/main/java/org/apache/kafka/message/MessageGenerator.java b/generator/src/main/java/org/apache/kafka/message/MessageGenerator.java
@@ -165,6 +165,7 @@ public final class MessageGenerator {
         JSON_SERDE = new ObjectMapper();
         JSON_SERDE.configure(SerializationFeature.FAIL_ON_EMPTY_BEANS, false);
         JSON_SERDE.configure(DeserializationFeature.ACCEPT_SINGLE_VALUE_AS_ARRAY, true);
+        JSON_SERDE.configure(DeserializationFeature.FAIL_ON_TRAILING_TOKENS, true);
         JSON_SERDE.configure(JsonParser.Feature.ALLOW_COMMENTS, true);
         JSON_SERDE.setSerializationInclusion(JsonInclude.Include.NON_EMPTY);
     }

Original file line number	Diff line number	Diff line change
`@@ -165,6 +165,7 @@ public final class MessageGenerator {`
`165`	`165`	`JSON_SERDE = new ObjectMapper();`
`166`	`166`	`JSON_SERDE.configure(SerializationFeature.FAIL_ON_EMPTY_BEANS, false);`
`167`	`167`	`JSON_SERDE.configure(DeserializationFeature.ACCEPT_SINGLE_VALUE_AS_ARRAY, true);`
	`168`	`+ JSON_SERDE.configure(DeserializationFeature.FAIL_ON_TRAILING_TOKENS, true);`
`168`	`169`	`JSON_SERDE.configure(JsonParser.Feature.ALLOW_COMMENTS, true);`
`169`	`170`	`JSON_SERDE.setSerializationInclusion(JsonInclude.Include.NON_EMPTY);`
`170`	`171`	`}`