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)