This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit d25529dc92f03b1fb2afd3b9883ce2a8f5a86a9c Author: Mathieu <[email protected]> AuthorDate: Wed Jun 23 23:02:50 2021 +0200 Fix InputStream --- .../kafkaconnector/aws2s3/transformers/RecordToJSONTransforms.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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.kafka.connect.transforms.Transformation; 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 @@ public class RecordToJSONTransforms<R extends ConnectRecord<R>> implements Trans 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(),
