fix: More correctly report starting phase during kafka-reader startup (…

…#14632)
grafana · Oct 29, 2024 · ea798e0 · ea798e0
1 parent db0889e
commit ea798e0
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/kafka/partition/reader.go b/pkg/kafka/partition/reader.go
@@ -477,7 +477,7 @@ func (p *Reader) recordFetchesMetrics(fetches kgo.Fetches) {
 	fetches.EachRecord(func(record *kgo.Record) {
 		numRecords++
 		delay := now.Sub(record.Timestamp).Seconds()
-		if p.lastProcessedOffset == -1 {
+		if p.Service.State() == services.Starting {
 			p.metrics.receiveDelayWhenStarting.Observe(delay)
 		} else {
 			p.metrics.receiveDelayWhenRunning.Observe(delay)