varnitgoyal95/janus
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

NA | Shubham | comment out successful write log

Browse Source
This commit is contained in:
Shubham Kumar
2022-09-21 12:06:24 +05:30
committed by GitHub Enterprise
parent c19ab662ec
commit f8aa655b69
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
producer/kafka_writer.go
View File

@@ -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)