You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by or...@apache.org on 2021/03/03 08:06:03 UTC

[camel-kafka-connector] 03/11: Rename the avroData bytes to avoid confusion with the member variable also named avroData

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

commit b760daef397370e0db0e44d051dec4befb756627
Author: Otavio Rodolfo Piske <op...@redhat.com>
AuthorDate: Wed Feb 24 11:35:30 2021 +0100

    Rename the avroData bytes to avoid confusion with the member variable also named avroData
---
 .../kafkaconnector/transforms/SinkPojoToSchemaAndStructTransform.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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 0ccc6fc..0da7ca4 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
@@ -79,10 +79,10 @@ public class SinkPojoToSchemaAndStructTransform<R extends ConnectRecord<R>> impl
                 writer.write(avroGenericRecord, encoder);
                 encoder.flush();
 
-                byte[] avroData = out.toByteArray();
+                byte[] avroDataBytes = out.toByteArray();
                 pojo = objectReader
                         .with(new AvroSchema(avroGenericRecord.getSchema()))
-                        .readValue(avroData);
+                        .readValue(avroDataBytes);
                 LOG.debug("Pojo of class {} created: {}", pojo.getClass(), pojo);
             } catch (IOException e) {
                 throw new ConnectException("Error in generating POJO from Struct.", e);