From 85e980ab9223974647234cf5733548a3d240b6de Mon Sep 17 00:00:00 2001 From: Lucas Martins <38249173+lmsilva-wls@users.noreply.github.com> Date: Tue, 6 Dec 2022 11:19:04 -0300 Subject: [PATCH] Include log on SendEvent endpoint (#23) --- sender/kafka.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/sender/kafka.go b/sender/kafka.go index a2c3deb..5dd86f9 100644 --- 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 }