From f04bba4170c2301133ae3185b99b44cf9cb92781 Mon Sep 17 00:00:00 2001 From: Neil Alexander Date: Tue, 10 Aug 2021 14:50:35 +0100 Subject: [PATCH] Producer logging --- keyserver/producers/signingupdate.go | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) diff --git a/keyserver/producers/signingupdate.go b/keyserver/producers/signingupdate.go index cfe1dde73..450ec50d6 100644 --- a/keyserver/producers/signingupdate.go +++ b/keyserver/producers/signingupdate.go @@ -19,6 +19,7 @@ import ( "github.com/Shopify/sarama" "github.com/matrix-org/dendrite/eduserver/api" + "github.com/sirupsen/logrus" ) type SigningKeyUpdate struct { @@ -46,6 +47,12 @@ func (p *SigningKeyUpdate) ProduceSigningKeyUpdate(key api.SigningKeyUpdate) err m.Value = sarama.ByteEncoder(value) _, _, err = p.Producer.SendMessage(&m) + if err != nil { + return err + } - return err + logrus.WithFields(logrus.Fields{ + "user_id": key.UserID, + }).Infof("Produced to cross-signing update topic '%s'", p.Topic) + return nil }