-
Notifications
You must be signed in to change notification settings - Fork 3.6k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
feat: add loki_ingest_limits_kafka_consumption_lag_seconds metric #16886
feat: add loki_ingest_limits_kafka_consumption_lag_seconds metric #16886
Conversation
This commit fixes a previous metric that did not measure consumption lag as intended, replacing it with a new metric that estimates the consumption lag in seconds using the timestamp in the record.
fc1beff
to
27e0d67
Compare
Namespace: constants.Loki, | ||
Name: "ingest_limits_kafka_read_latency_seconds", | ||
Help: "Latency to read stream metadata from Kafka.", | ||
kafkaConsumptionLag: promauto.With(reg).NewHistogram(prometheus.HistogramOpts{ |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I am reluctant to put the partition as a label here to avoid really high cardinality (one histogram each for 1000 partitions).
Name: "ingest_limits_kafka_read_latency_seconds", | ||
Help: "Latency to read stream metadata from Kafka.", | ||
kafkaConsumptionLag: promauto.With(reg).NewHistogram(prometheus.HistogramOpts{ | ||
Name: "loki_ingest_limits_kafka_consumption_lag_seconds", |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Also renamed to match loki_kafka_reader_consumption_lag_seconds
.
What this PR does / why we need it:
This pull request adds a new metric to the ingest-limits service to track consumption lag in seconds.
Which issue(s) this PR fixes:
Fixes #
Special notes for your reviewer:
Checklist
CONTRIBUTING.md
guide (required)feat
PRs are unlikely to be accepted unless a case can be made for the feature actually being a bug fix to existing behavior.docs/sources/setup/upgrade/_index.md
deprecated-config.yaml
anddeleted-config.yaml
files respectively in thetools/deprecated-config-checker
directory. Example PR