add missing memberlist init

cyriltovena · Sep 6, 2024 · f007c75 · f007c75
1 parent ddacb06
commit f007c75
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pkg/loki/modules.go b/pkg/loki/modules.go
@@ -1502,6 +1502,7 @@ func (t *Loki) initMemberlistKV() (services.Service, error) {
 	t.Cfg.Pattern.LifecyclerConfig.RingConfig.KVStore.MemberlistKV = t.MemberlistKV.GetMemberlistKV
 	t.Cfg.IngesterRF1.LifecyclerConfig.RingConfig.KVStore.MemberlistKV = t.MemberlistKV.GetMemberlistKV
 	t.Cfg.KafkaIngester.PartitionRingConfig.KVStore.MemberlistKV = t.MemberlistKV.GetMemberlistKV
+	t.Cfg.KafkaIngester.LifecyclerConfig.RingConfig.KVStore.MemberlistKV = t.MemberlistKV.GetMemberlistKV
 	t.Server.HTTP.Handle("/memberlist", t.MemberlistKV)
 
 	if t.Cfg.InternalServer.Enable {