resolved merge conflicts

producer/kafka_writer.go

@@ -13,7 +13,7 @@ func WriteMessageToKafkaAsync(message *sarama.ProducerMessage, source string) {
 	asyncProducer.Input() <- message
 	metrics.KafkaPushTimeHist.WithLabelValues(message.Topic, source).Observe(float64(utils.NanosToMillis(time.Now().UnixNano()) - beforeKafkaPushTime))
 	metrics.KafkaPushCounter.WithLabelValues(message.Topic, source).Inc()
-	logger.Info("SUCCESSFULLY WRITTEN TO KAFKA FOR SOURCE " + source)
+	logger.Debug("SUCCESSFULLY WRITTEN TO KAFKA FOR SOURCE " + source)
 }
 
 func processProducerSuccesses() {
@@ -29,5 +29,4 @@ func processProducerErrors() {
 		logger.Error("Failed to write message to Kafka", zap.Error(err.Err))
 		metrics.ProducerFailCounter.WithLabelValues(err.Msg.Topic).Inc()
 	}
-
 }