Fix empty logger error (#139)

agbpatro · web-flow · commit 9e2f2d0f7455 · 2024-03-31T13:29:36.000-07:00
diff --git a/datastore/kafka/kafka.go b/datastore/kafka/kafka.go
@@ -49,12 +49,13 @@ func NewProducer(config *kafka.ConfigMap, namespace string, reliableAckWorkers i
 		namespace:         namespace,
 		metricsCollector:  metricsCollector,
 		prometheusEnabled: prometheusEnabled,
+		logger:            logger,
 	}
 
 	for i := 0; i < reliableAckWorkers; i++ {
 		go producer.handleProducerEvents(ackChan)
 	}
-	logger.Infof("registered kafka for namespace: %s", namespace)
+	producer.logger.Infof("registered kafka for namespace: %s", namespace)
 	return producer, nil
 }
 

Original file line number	Diff line number	Diff line change
`@@ -49,12 +49,13 @@ func NewProducer(config *kafka.ConfigMap, namespace string, reliableAckWorkers i`
`49`	`49`	`namespace: namespace,`
`50`	`50`	`metricsCollector: metricsCollector,`
`51`	`51`	`prometheusEnabled: prometheusEnabled,`
	`52`	`+ logger: logger,`
`52`	`53`	`}`
`53`	`54`
`54`	`55`	`for i := 0; i < reliableAckWorkers; i++ {`
`55`	`56`	`go producer.handleProducerEvents(ackChan)`
`56`	`57`	`}`
`57`		`- logger.Infof("registered kafka for namespace: %s", namespace)`
	`58`	`+ producer.logger.Infof("registered kafka for namespace: %s", namespace)`
`58`	`59`	`return producer, nil`
`59`	`60`	`}`
`60`	`61`