From 8438d415931f0a3763d551eb36c3d9f476f70713 Mon Sep 17 00:00:00 2001 From: Cyril Tovena Date: Fri, 4 Oct 2024 15:07:17 +0200 Subject: [PATCH] fix(distributor): validate partition ring is kafka is enabled (#14303) --- pkg/loki/modules.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/pkg/loki/modules.go b/pkg/loki/modules.go index 4c718722a509f..d9c111cc86493 100644 --- a/pkg/loki/modules.go +++ b/pkg/loki/modules.go @@ -322,6 +322,10 @@ func (t *Loki) initTenantConfigs() (_ services.Service, err error) { func (t *Loki) initDistributor() (services.Service, error) { t.Cfg.Distributor.KafkaConfig = t.Cfg.KafkaConfig + if t.Cfg.Distributor.KafkaEnabled && !t.Cfg.Ingester.KafkaIngestion.Enabled { + return nil, errors.New("kafka is enabled in distributor but not in ingester") + } + var err error logger := log.With(util_log.Logger, "component", "distributor") t.distributor, err = distributor.New(