Merge pull request #637 from confluentinc/remove-record-logging

removed logging from different writer providers

Author: akash-borkar

src/main/java/io/confluent/connect/hdfs/avro/AvroRecordWriterProvider.java

@@ -73,7 +73,6 @@ public void write(SinkRecord record) {
           }
         }
 
-        log.trace("Sink record: {}", record);
         Object value = avroData.fromConnectData(schema, record.value());
         try {
           // AvroData wraps primitive types so their schema can be included. We need to unwrap

src/main/java/io/confluent/connect/hdfs/json/JsonRecordWriterProvider.java

@@ -76,7 +76,6 @@ public RecordWriter getRecordWriter(final HdfsSinkConnectorConfig conf, final St
 
         @Override
         public void write(SinkRecord record) {
-          log.trace("Sink record: {}", record.toString());
           try {
             Object value = record.value();
             if (value instanceof Struct) {

src/main/java/io/confluent/connect/hdfs/parquet/ParquetRecordWriterProvider.java

@@ -95,7 +95,6 @@ public void write(SinkRecord record) {
           }
         }
 
-        log.trace("Sink record: {}", record);
         Object value = avroData.fromConnectData(record.valueSchema(), record.value());
         try {
           writer.write((GenericRecord) value);

src/main/java/io/confluent/connect/hdfs/string/StringRecordWriterProvider.java

@@ -69,7 +69,6 @@ public RecordWriter getRecordWriter(final HdfsSinkConnectorConfig conf, final St
 
         @Override
         public void write(SinkRecord record) {
-          log.trace("Sink record: {}", record.toString());
           try {
             String value = (String) record.value();
             writer.write(value);