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)