commit d25529dc92f03b1fb2afd3b9883ce2a8f5a86a9c
author Mathieu <mathieux51@gmail.com> Wed Jun 23 23:02:50 2021 +0200
committer Andrea Cosentino <ancosen@gmail.com> Thu Jul 22 08:08:54 2021 +0200
tree 7ced986eb9e7fa6afa6f431df41d0f5c22bf79de
parent c13dd1f849925da51b0a1a92f30cc2611888cad3

Fix InputStream

connectors/camel-aws2-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2s3/transformers/RecordToJSONTransforms.java

diff --git a/connectors/camel-aws2-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2s3/transformers/RecordToJSONTransforms.java b/connectors/camel-aws2-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2s3/transformers/RecordToJSONTransforms.java
index fdb2e9f..203ab14 100644
--- a/connectors/camel-aws2-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2s3/transformers/RecordToJSONTransforms.java
+++ b/connectors/camel-aws2-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2s3/transformers/RecordToJSONTransforms.java
@@ -29,6 +29,7 @@
 import org.apache.camel.kafkaconnector.aws2s3.models.StorageHeader;
 import org.apache.camel.kafkaconnector.aws2s3.models.StorageRecord;
 import java.io.ByteArrayInputStream;
+import java.io.InputStream;
 
 public class RecordToJSONTransforms<R extends ConnectRecord<R>> implements Transformation<R> {
   public static final String FIELD_KEY_CONFIG = "key";
@@ -61,7 +62,7 @@
     GsonBuilder gsonBuilder = new GsonBuilder();
     Gson gson = gsonBuilder.create();
     String storageRecordJSON = gson.toJson(storageRecord, StorageRecord.class);
-    InputStream storageRecordStream = new ByteArrayInputStream(storageRecordJSON.getBytes())
+    InputStream storageRecordStream = new ByteArrayInputStream(storageRecordJSON.getBytes());
     return record.newRecord(
         record.topic(),
         record.kafkaPartition(),