Include log on SendEvent endpoint (#23)

topfreegames · Dec 6, 2022 · 85e980a · 85e980a
1 parent 7ca8c12
commit 85e980a
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/sender/kafka.go b/sender/kafka.go
@@ -105,6 +105,8 @@ func (k *KafkaSender) SendEvent(
 	topic := event.GetTopic()
 	partition, offset, err := k.producer.Produce(ctx, topic, buf.Bytes())
 	if err != nil {
+		l.WithError(err).
+			Error("error producing event to kafka")
 		metrics.APITopicsSubmission.WithLabelValues(topic, "false").Inc()
 		return err
 	}