Skip to content
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

Conversation

grobinson-grafana
Copy link
Contributor

@grobinson-grafana grobinson-grafana commented Mar 24, 2025

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

  • Reviewed the CONTRIBUTING.md guide (required)
  • Documentation added
  • Tests updated
  • Title matches the required conventional commits format, see here
    • Note that Promtail is considered to be feature complete, and future development for logs collection will be in Grafana Alloy. As such, feat PRs are unlikely to be accepted unless a case can be made for the feature actually being a bug fix to existing behavior.
  • Changes that require user attention or interaction to upgrade are documented in docs/sources/setup/upgrade/_index.md
  • If the change is deprecating or removing a configuration option, update the deprecated-config.yaml and deleted-config.yaml files respectively in the tools/deprecated-config-checker directory. Example PR

@grobinson-grafana grobinson-grafana requested a review from a team as a code owner March 24, 2025 20:16
@grobinson-grafana grobinson-grafana marked this pull request as draft March 24, 2025 21:28
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.
@grobinson-grafana grobinson-grafana marked this pull request as ready for review March 25, 2025 09:33
@grobinson-grafana grobinson-grafana force-pushed the grobinson/add-kafka-consumption-lag-metric-ingest-limits branch from fc1beff to 27e0d67 Compare March 25, 2025 09:33
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{
Copy link
Contributor Author

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",
Copy link
Contributor Author

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.

@grobinson-grafana grobinson-grafana merged commit b35343b into main Mar 25, 2025
61 checks passed
@grobinson-grafana grobinson-grafana deleted the grobinson/add-kafka-consumption-lag-metric-ingest-limits branch March 25, 2025 09:59
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants