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);