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 <[email protected]> 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);
