diff --git a/federationapi/consumers/keychange.go b/federationapi/consumers/keychange.go index adba58000..8231fcf44 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,