Merge pull request #639 from confluentinc/pr_merge_from_4_1_x_to_5_0_x

Merge Conflict Resolution (from 4.1.x to 5.0.x)

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

@@ -74,7 +74,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

@@ -63,7 +63,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);