From b4cc781832652d25992c9ded161d758607eee757 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Andr=C3=A9=20Duffeck?= Date: Tue, 29 Jul 2025 14:19:00 +0200 Subject: [PATCH] Do not try to log metrics when we failed to get the consumer info Fixes #1285 --- services/postprocessing/pkg/service/service.go | 1 + services/search/pkg/search/events.go | 1 + 2 files changed, 2 insertions(+) diff --git a/services/postprocessing/pkg/service/service.go b/services/postprocessing/pkg/service/service.go index 886d0599a5..c57082509d 100644 --- a/services/postprocessing/pkg/service/service.go +++ b/services/postprocessing/pkg/service/service.go @@ -393,6 +393,7 @@ func monitorMetrics(stream raw.Stream, name string, m *metrics.Metrics, logger l info, err := consumer.Info(ctx) if err != nil { logger.Error().Err(err).Msg("failed to get consumer") + continue } m.EventsOutstandingAcks.Set(float64(info.NumAckPending)) diff --git a/services/search/pkg/search/events.go b/services/search/pkg/search/events.go index a02286d9c7..15da2efb0f 100644 --- a/services/search/pkg/search/events.go +++ b/services/search/pkg/search/events.go @@ -122,6 +122,7 @@ func monitorMetrics(stream raw.Stream, name string, m *metrics.Metrics, logger l info, err := consumer.Info(ctx) if err != nil { logger.Error().Err(err).Msg("failed to get consumer") + continue } m.EventsOutstandingAcks.Set(float64(info.NumAckPending))