[camel-kafka-connector] 02/03: Fixed CS

[acosentino]

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch file-transforms-camel-master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git

commit 136dade366aec999669fdb9634e6acbd19effd8b
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Wed Feb 24 10:47:42 2021 +0100

    Fixed CS
---
 .../file/transformers/FileTransforms.java          | 27 +++++++++-------------
 1 file changed, 11 insertions(+), 16 deletions(-)

diff --git 
a/connectors/camel-file-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/file/transformers/FileTransforms.java
 
b/connectors/camel-file-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/file/transformers/FileTransforms.java
index 173ed11..7c82441 100644
--- 
a/connectors/camel-file-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/file/transformers/FileTransforms.java
+++ 
b/connectors/camel-file-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/file/transformers/FileTransforms.java
@@ -17,8 +17,6 @@
 package org.apache.camel.kafkaconnector.file.transformers;
 
 import java.io.File;
-import java.io.FileNotFoundException;
-import java.io.FileReader;
 import java.io.IOException;
 import java.nio.charset.StandardCharsets;
 import java.util.Map;
@@ -32,11 +30,9 @@ import org.apache.kafka.connect.transforms.Transformation;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-public class FileTransforms <R extends ConnectRecord<R>> implements 
Transformation<R> {
+public class FileTransforms<R extends ConnectRecord<R>> implements 
Transformation<R> {
     public static final String FIELD_KEY_CONFIG = "key";
-    public static final ConfigDef CONFIG_DEF = new ConfigDef()
-            .define(FIELD_KEY_CONFIG, ConfigDef.Type.STRING, null, 
ConfigDef.Importance.MEDIUM,
-                    "Transforms File to String");
+    public static final ConfigDef CONFIG_DEF = new 
ConfigDef().define(FIELD_KEY_CONFIG, ConfigDef.Type.STRING, null, 
ConfigDef.Importance.MEDIUM, "Transforms File to String");
 
     private static final Logger LOG = 
LoggerFactory.getLogger(FileTransforms.class);
 
@@ -46,17 +42,16 @@ public class FileTransforms <R extends ConnectRecord<R>> 
implements Transformati
 
         if (r.value() instanceof GenericFile) {
             LOG.debug("Converting record from RemoteFile to text");
-            GenericFile<File> message = (GenericFile<File>) r.value();
+            GenericFile<File> message = (GenericFile<File>)r.value();
             String c = null;
-                       try {
-                               c = 
FileUtils.readFileToString(message.getFile(), StandardCharsets.UTF_8);
-                       } catch (IOException e) {
-                               // TODO Auto-generated catch block
-                               e.printStackTrace();
-                       }
-            
-            return r.newRecord(r.topic(), r.kafkaPartition(), null, r.key(),
-                    SchemaHelper.buildSchemaBuilderForType(c), c, 
r.timestamp());
+            try {
+                c = FileUtils.readFileToString(message.getFile(), 
StandardCharsets.UTF_8);
+            } catch (IOException e) {
+                // TODO Auto-generated catch block
+                e.printStackTrace();
+            }
+
+            return r.newRecord(r.topic(), r.kafkaPartition(), null, r.key(), 
SchemaHelper.buildSchemaBuilderForType(c), c, r.timestamp());
 
         } else {
             LOG.debug("Unexpected message type: {}", r.value().getClass());