Merge pull request #15 from medici/shubham-kumar-patch-1

NA | Shubham | comment out successful write log

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)