Do not try to log metrics when we failed to get the consumer info

Fixes #1285
This commit is contained in:
André Duffeck
2025-07-29 14:19:00 +02:00
parent 2670f24605
commit b4cc781832
2 changed files with 2 additions and 0 deletions

View File

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