From f8aa655b69e6ad49e1f925b1538d8ae6122a61fb Mon Sep 17 00:00:00 2001
From: Shubham Kumar <shubham.kumar@navi.com>
Date: Wed, 21 Sep 2022 12:06:24 +0530
Subject: [PATCH] NA | Shubham | comment out successful write log

---
 producer/kafka_writer.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/producer/kafka_writer.go b/producer/kafka_writer.go
index 25fee79..2d8e07b 100644
--- a/producer/kafka_writer.go
+++ b/producer/kafka_writer.go
@@ -11,7 +11,7 @@ func WriteMessageToKafkaAsync(message *sarama.ProducerMessage, source string) {
     select {
         case asyncProducer.Input() <- message:
             metrics.IncrementCounter("success", source)
-            log.Printf("SUCCESSFULLY WRITTEN TO KAFKA FOR SOURCE %v", source)
+//             log.Printf("SUCCESSFULLY WRITTEN TO KAFKA FOR SOURCE %v", source)
         case err := <- asyncProducer.Errors():
             metrics.IncrementCounter("fail", source)
             log.Printf("FAILED TO WRITE TO KAFKA FOR SOURCE %v %v", source, err)