From 066aeb40b4c539e0f8895ee1cfb731cd9176fa90 Mon Sep 17 00:00:00 2001 From: Neil Alexander Date: Wed, 5 Jan 2022 13:46:57 +0000 Subject: [PATCH] Fix consumer component name in federation API --- federationapi/consumers/keychange.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/federationapi/consumers/keychange.go b/federationapi/consumers/keychange.go index adba5800..8231fcf4 100644 --- a/federationapi/consumers/keychange.go +++ b/federationapi/consumers/keychange.go @@ -56,7 +56,7 @@ func NewKeyChangeConsumer( ctx: process.Context(), consumer: &internal.ContinualConsumer{ Process: process, - ComponentName: "federationsender/keychange", + ComponentName: "federationapi/keychange", Topic: string(cfg.Matrix.JetStream.TopicFor(jetstream.OutputKeyChangeEvent)), Consumer: kafkaConsumer, PartitionStore: store,