You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Mark Tinsley (Jira)" <ji...@apache.org> on 2019/11/14 20:49:00 UTC

[jira] [Created] (KAFKA-9192) NullPointerException if field in schema not present in value

Mark Tinsley created KAFKA-9192:
-----------------------------------

             Summary: NullPointerException if field in schema not present in value
                 Key: KAFKA-9192
                 URL: https://issues.apache.org/jira/browse/KAFKA-9192
             Project: Kafka
          Issue Type: Bug
          Components: KafkaConnect
    Affects Versions: 2.2.1
            Reporter: Mark Tinsley


Given a message:
{code:java}
{
   "schema":{
      "type":"struct",
      "fields":[
         {
            "type":"string",
            "optional":true,
            "field":"abc"
         }
      ],
      "optional":false,
      "name":"foobar"
   },
   "payload":{
   }
}
{code}


I would expect, given the field is optional, for the JsonConverter to still process this value. 

What happens is I get a null pointer exception, the stacktrace points to this line: https://github.com/apache/kafka/blob/2.1/connect/json/src/main/java/org/apache/kafka/connect/json/JsonConverter.java#L701 called by https://github.com/apache/kafka/blob/2.1/connect/json/src/main/java/org/apache/kafka/connect/json/JsonConverter.java#L181

Issue seems to be that we need to check and see if the jsonValue is null before checking if the jsonValue has a null value.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)