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))