fix issue with Avro record default values in Kafka Connect converter

jurgispods · jurgispods · commit 00e84e0ca6cc · 2023-11-08T14:43:35.000+01:00
diff --git a/avro-kafkaconnect-converter/src/main/java/com/amazonaws/services/schemaregistry/kafkaconnect/avrodata/AvroData.java b/avro-kafkaconnect-converter/src/main/java/com/amazonaws/services/schemaregistry/kafkaconnect/avrodata/AvroData.java
@@ -1225,7 +1225,7 @@ private Object toConnectData(Schema schema, Object value, ToConnectContext toCon
     private Object toConnectData(Schema schema, Object value, ToConnectContext toConnectContext,
                                  boolean doLogicalConversion) {
         validateSchemaValue(schema, value);
-        if (value == null) {
+        if (value == null || value == JsonProperties.NULL_VALUE) {
             return null;
         }
         try {

Original file line number	Diff line number	Diff line change
`@@ -1225,7 +1225,7 @@ private Object toConnectData(Schema schema, Object value, ToConnectContext toCon`
`1225`	`1225`	`private Object toConnectData(Schema schema, Object value, ToConnectContext toConnectContext,`
`1226`	`1226`	`boolean doLogicalConversion) {`
`1227`	`1227`	`validateSchemaValue(schema, value);`
`1228`		`- if (value == null) {`
	`1228`	`+ if (value == null \|\| value == JsonProperties.NULL_VALUE) {`
`1229`	`1229`	`return null;`
`1230`	`1230`	`}`
`1231`	`1231`	`try {`