removed logging from different writer providers

confluentinc · Nov 28, 2022 · 16926bd · 16926bd
1 parent a2bb25e
commit 16926bd
Show file tree

Hide file tree

Showing 4 changed files with 0 additions and 4 deletions.
diff --git a/src/main/java/io/confluent/connect/hdfs/avro/AvroRecordWriterProvider.java b/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

diff --git a/src/main/java/io/confluent/connect/hdfs/json/JsonRecordWriterProvider.java b/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) {

diff --git a/src/main/java/io/confluent/connect/hdfs/parquet/ParquetRecordWriterProvider.java b/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);

diff --git a/src/main/java/io/confluent/connect/hdfs/string/StringRecordWriterProvider.java b/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);