[camel-kafka-connector] branch master updated: Prevents a potential null pointer dereference if the conversion cannot be made in the SinkPojoToSchemaAndStructTransform

[or...@apache.org]

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

orpiske pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git


The following commit(s) were added to refs/heads/master by this push:
     new 2176af8  Prevents a potential null pointer dereference if the conversion cannot be made in the SinkPojoToSchemaAndStructTransform
2176af8 is described below

commit 2176af8eb5056b8cf6e1219c5703150c28940bed
Author: Otavio Rodolfo Piske <op...@redhat.com>
AuthorDate: Fri Dec 11 17:25:26 2020 +0100

    Prevents a potential null pointer dereference if the conversion cannot be made in the SinkPojoToSchemaAndStructTransform
---
 .../transforms/SinkPojoToSchemaAndStructTransform.java            | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git a/core/src/main/java/org/apache/camel/kafkaconnector/transforms/SinkPojoToSchemaAndStructTransform.java b/core/src/main/java/org/apache/camel/kafkaconnector/transforms/SinkPojoToSchemaAndStructTransform.java
index 30ef9ca..ac15280 100644
--- a/core/src/main/java/org/apache/camel/kafkaconnector/transforms/SinkPojoToSchemaAndStructTransform.java
+++ b/core/src/main/java/org/apache/camel/kafkaconnector/transforms/SinkPojoToSchemaAndStructTransform.java
@@ -63,7 +63,13 @@ public class SinkPojoToSchemaAndStructTransform<R extends ConnectRecord<R>> impl
         if (r.value() != null && r.valueSchema() != null && Schema.Type.STRUCT.equals(r.valueSchema().type())) {
             GenericRecord avroGenericRecord = (GenericRecord)avroData.fromConnectData(r.valueSchema(), r.value());
 
-            LOG.debug("GenericRecord created: {} \nwith schema: {}", avroGenericRecord, avroGenericRecord == null ? "null" : avroGenericRecord.getClass().getName());
+            if (avroGenericRecord == null) {
+                LOG.warn("No GenericRecord was converted as part of this transformation");
+
+                return r;
+            }
+
+            LOG.debug("GenericRecord created: {} \nwith schema: {}", avroGenericRecord, avroGenericRecord.getClass().getName());
 
             GenericDatumWriter<GenericRecord> writer = new GenericDatumWriter<GenericRecord>(avroGenericRecord.getSchema());