Skip to content

[metrics] Add last_poll_seconds_ago scanner metric#581

Open
charlesdong1991 wants to merge 2 commits into
apache:mainfrom
charlesdong1991:issue-554
Open

[metrics] Add last_poll_seconds_ago scanner metric#581
charlesdong1991 wants to merge 2 commits into
apache:mainfrom
charlesdong1991:issue-554

Conversation

@charlesdong1991
Copy link
Copy Markdown
Contributor

Purpose

Add lastPollSecondsAgo consumer-liveness gauge to fluss-rust, this is the primary signal for detecting stuck consumers, and it must keep advancing between poll events even when no new poll happen.

Note: metrics 0.24 facade has no scrape-time gauge supplier abstraction, so the value is pushed by a per-scanner 1-second background tokio task.

Linked issue: close #554

Brief change log

Tests

All tests passed.

API and Format

Documentation

@charlesdong1991
Copy link
Copy Markdown
Contributor Author

@fresh-borzoni @leekeiabstraction PTAL 🙏

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

[metrics] Add scanner last_poll_seconds_ago consumer liveness gauge

1 participant