diff options
Diffstat (limited to 'federationsender/consumers/keychange.go')
| -rw-r--r-- | federationsender/consumers/keychange.go | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/federationsender/consumers/keychange.go b/federationsender/consumers/keychange.go index c1136f10..4f206f5f 100644 --- a/federationsender/consumers/keychange.go +++ b/federationsender/consumers/keychange.go @@ -49,6 +49,7 @@ func NewKeyChangeConsumer( ) *KeyChangeConsumer { c := &KeyChangeConsumer{ consumer: &internal.ContinualConsumer{ + ComponentName: "federationsender/keychange", Topic: string(cfg.Matrix.Kafka.TopicFor(config.TopicOutputKeyChangeEvent)), Consumer: kafkaConsumer, PartitionStore: store, |