From d9ad97a70ca5963d692c88fe99e9aa09a5a1a892 Mon Sep 17 00:00:00 2001
From: Krishna Kondaka
 <krishkdk@dev-dsk-krishkdk-2c-bd29c437.us-west-2.amazon.com>
Date: Fri, 19 Jan 2024 16:57:07 +0000
Subject: [PATCH] Fixed failing spotless check

Signed-off-by: Krishna Kondaka <krishkdk@dev-dsk-krishkdk-2c-bd29c437.us-west-2.amazon.com>
---
 .../plugins/kafka/producer/KafkaCustomProducer.java          | 5 -----
 .../opensearch/dataprepper/plugins/kafka/sink/KafkaSink.java | 2 +-
 2 files changed, 1 insertion(+), 6 deletions(-)

diff --git a/data-prepper-plugins/kafka-plugins/src/main/java/org/opensearch/dataprepper/plugins/kafka/producer/KafkaCustomProducer.java b/data-prepper-plugins/kafka-plugins/src/main/java/org/opensearch/dataprepper/plugins/kafka/producer/KafkaCustomProducer.java
index a2aa2858e2..fe0291662b 100644
--- a/data-prepper-plugins/kafka-plugins/src/main/java/org/opensearch/dataprepper/plugins/kafka/producer/KafkaCustomProducer.java
+++ b/data-prepper-plugins/kafka-plugins/src/main/java/org/opensearch/dataprepper/plugins/kafka/producer/KafkaCustomProducer.java
@@ -87,9 +87,7 @@ public KafkaCustomProducer(final KafkaProducer producer,
         this.bufferedEventHandles = new LinkedList<>();
         this.expressionEvaluator = expressionEvaluator;
         this.tagTargetKey = tagTargetKey;
-        System.out.println("______________"+kafkaProducerConfig.getTopic());
         this.topicName = ObjectUtils.isEmpty(kafkaProducerConfig.getTopic()) ? null : kafkaProducerConfig.getTopic().getName();
-        System.out.println("2______________"+topicName);
         this.serdeFormat = ObjectUtils.isEmpty(kafkaProducerConfig.getSerdeFormat()) ? null : kafkaProducerConfig.getSerdeFormat();
         this.schemaService = schemaService;
         this.topicMetrics = topicMetrics;
@@ -102,7 +100,6 @@ KafkaTopicProducerMetrics getTopicMetrics() {
 
     public void produceRawData(final byte[] bytes, final String key) throws Exception{
         try {
-            System.out.println("+++++++++++"+topicName+"...."+key+"...."+bytes);
             send(topicName, key, bytes).get();
             topicMetrics.update(producer);
         } catch (Exception e) {
@@ -172,12 +169,10 @@ private void publishAvroMessage(final Record<Event> record, final String key) th
     }
 
     Future send(final String topicName, String key, final Object record) throws Exception {
-        System.out.println("0---------"+topicName+"---------"+key+"-----"+record);
         if (Objects.isNull(key)) {
             return producer.send(new ProducerRecord(topicName, record), callBack(record));
         }
 
-        System.out.println("1---------"+topicName+"---------"+key+"-----"+record);
         return producer.send(new ProducerRecord(topicName, key, record), callBack(record));
     }
 
diff --git a/data-prepper-plugins/kafka-plugins/src/main/java/org/opensearch/dataprepper/plugins/kafka/sink/KafkaSink.java b/data-prepper-plugins/kafka-plugins/src/main/java/org/opensearch/dataprepper/plugins/kafka/sink/KafkaSink.java
index 15203cd9c7..1adb77643b 100644
--- a/data-prepper-plugins/kafka-plugins/src/main/java/org/opensearch/dataprepper/plugins/kafka/sink/KafkaSink.java
+++ b/data-prepper-plugins/kafka-plugins/src/main/java/org/opensearch/dataprepper/plugins/kafka/sink/KafkaSink.java
@@ -28,7 +28,7 @@
 import org.opensearch.dataprepper.plugins.kafka.service.SchemaService;
 import org.opensearch.dataprepper.plugins.kafka.service.TopicService;
 import org.opensearch.dataprepper.plugins.kafka.util.RestUtils;
-import org.opensearch.dataprepper.plugins.kafka.sink.DLQSink;
+//import org.opensearch.dataprepper.plugins.kafka.sink.DLQSink;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;