We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent fc153f4 commit 0497c6bCopy full SHA for 0497c6b
pkg/kafka/partition/reader.go
@@ -58,7 +58,7 @@ func NewReaderMetrics(r prometheus.Registerer) *ReaderMetrics {
58
return &ReaderMetrics{
59
consumptionLag: promauto.With(r).NewGaugeVec(prometheus.GaugeOpts{
60
Name: "loki_kafka_reader_consumption_lag_seconds",
61
- Help: "Delay between producing a record and receiving it.",
+ Help: "The estimated consumption lag in seconds, measured as the difference between the current time and the timestamp of the record.",
62
}, []string{"phase"}),
63
fetchWaitDuration: promauto.With(r).NewHistogram(prometheus.HistogramOpts{
64
Name: "loki_kafka_reader_fetch_wait_duration_seconds",
0 commit comments