[kafka] branch trunk updated: KAFKA-12800: Configure generator to fail on trailing JSON tokens (#10717)

[dajac]

This is an automated email from the ASF dual-hosted git repository.

dajac pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 63b6db3  KAFKA-12800: Configure generator to fail on trailing JSON 
tokens (#10717)
63b6db3 is described below

commit 63b6db39b55e63c98aaf69ad79b9de21e135ac8f
Author: Nathan Lincoln <lincolnnathan...@gmail.com>
AuthorDate: Tue May 25 08:12:48 2021 -0500

    KAFKA-12800: Configure generator to fail on trailing JSON tokens (#10717)
    
    Reviewers: David Jacot <dja...@confluent.io>
---
 generator/src/main/java/org/apache/kafka/message/MessageGenerator.java | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/generator/src/main/java/org/apache/kafka/message/MessageGenerator.java 
b/generator/src/main/java/org/apache/kafka/message/MessageGenerator.java
index a1b9728..cfbeae8 100644
--- 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);
     }