Skip to content

Cherry-pick #14822 to 7.x: Add consumer_lag in Kafka consumergroup metricset#14851

Merged
ChrsMark merged 1 commit intoelastic:7.xfrom
ChrsMark:backport_14822_7.x
Nov 29, 2019
Merged

Cherry-pick #14822 to 7.x: Add consumer_lag in Kafka consumergroup metricset#14851
ChrsMark merged 1 commit intoelastic:7.xfrom
ChrsMark:backport_14822_7.x

Conversation

@ChrsMark
Copy link
Copy Markdown
Member

@ChrsMark ChrsMark commented Nov 29, 2019

Cherry-pick of PR #14822 to 7.x branch. Original message:

This PR adds consumer_lag field in consumergroup metricset. This is calculated by subtracting groupOffset from partitionOffset for a partition-topic pair.

partitionOffset is retrieved from the cluster directly using https://github.com/Shopify/sarama/blob/afedecade3c6d8e99ab6dfeeea7814bf800b90a4/client.go#L62

May resolve_ #3608.

Signed-off-by: chrismark chrismarkou92@gmail.com

@ChrsMark ChrsMark requested a review from a team as a code owner November 29, 2019 08:24
@ChrsMark ChrsMark self-assigned this Nov 29, 2019
@ChrsMark ChrsMark added [zube]: In Review Team:Integrations Label for the Integrations team labels Nov 29, 2019
@ChrsMark ChrsMark merged commit 311bab6 into elastic:7.x Nov 29, 2019
@zube zube Bot added [zube]: Done and removed [zube]: Inbox labels Nov 29, 2019
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

backport review Team:Integrations Label for the Integrations team

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants