fix(distributor): Activate partition ring is kafka is enabled

grafana · Sep 28, 2024 · 7799989 · 7799989
1 parent 84788ad
commit 7799989
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/loki/modules.go b/pkg/loki/modules.go
@@ -1753,7 +1753,7 @@ func (t *Loki) initAnalytics() (services.Service, error) {
 
 // The Ingest Partition Ring is responsible for watching the available ingesters and assigning partitions to incoming requests.
 func (t *Loki) initPartitionRing() (services.Service, error) {
-	if !t.Cfg.Ingester.KafkaIngestion.Enabled {
+	if !t.Cfg.Ingester.KafkaIngestion.Enabled && !t.Cfg.Distributor.KafkaEnabled {
 		return nil, nil
 	}