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.

Sign up for GitHub

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

Update metric exporter to report lag as unit of time #2

Merged

davidmparrott merged 3 commits into master from metric_testing

Dec 11, 2020

Owner

davidmparrott commented Dec 11, 2020

Exporter will now, additionally, report a metric for kafka consumer lag as a unit of time.

Created additional function in collect to perform lag estimation
Information about current produced offsets is added during consumer group metric collection
Interpolation table is now separate file containing relevant struct and methods
Prune added, which can be called at any time to iterate of the interpolation table and remove stale and overly large data
Added ticker to perform pruning at a configurable interval

davidmparrott added 3 commits

December 9, 2020 16:58

WIP

3c8653f


Separate interpolation table into it's own file.

4b0dc5c

Update README to reflect additional functionality


Add slow_producer.go and slow_consumer.go to examples

9e109b0

davidmparrott merged commit 674a5c9 into master

davidmparrott deleted the metric_testing branch

January 29, 2021 00:12

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