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

Collect metrics of Kafka consumer groups without active members #23077

Open
jsoriano opened this issue Dec 10, 2020 · 6 comments
Open

Collect metrics of Kafka consumer groups without active members #23077

jsoriano opened this issue Dec 10, 2020 · 6 comments
Labels
bug Metricbeat Metricbeat module Team:Service-Integrations Label for the Service Integrations team

Comments

@jsoriano
Copy link
Member

jsoriano commented Dec 10, 2020

consumergroup metricset of the Metricbeat kafka module collects consumer group metrics per member in the consumer group. When a consumer group doesn't have any active member, it doesn't collect any data, but this can be important to detect that all members are down, and to keep visualizing the last processed offsets.

Metricbeat should be able to collect metrics both, per consumergroup and per member.

I see two options for that:

  • Split the consumergroup metricset in two, one for consumergroups, and another one for members. The one for members should take care of collecting the consumer lag for each member.
  • In current consumergroup, generate an event for consumergroups that don't have any member, without the member-specific fields.

Example consumer group without members:

# ./kafka/bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --command-config /kafka/bin/sasl-consumer.properties --describe --group foo-1
Picked up _JAVA_OPTIONS: -Djava.net.preferIPv4Stack=true
Consumer group 'foo-1' has no active members.

TOPIC           PARTITION  CURRENT-OFFSET  LOG-END-OFFSET  LAG             CONSUMER-ID     HOST            CLIENT-ID
foo             0          1               2               1               -               -               -
foo             1          1               3               2               -               -               -
@jsoriano jsoriano added module Metricbeat Metricbeat Team:Services (Deprecated) Label for the former Integrations-Services team labels Dec 10, 2020
@MeijerM1
Copy link

Is there an update on this?

@jsoriano jsoriano added the Team:Integrations Label for the Integrations team label Jan 10, 2022
@elasticmachine
Copy link
Collaborator

Pinging @elastic/integrations (Team:Integrations)

@jsoriano jsoriano added the bug label Jan 24, 2022
@jlind23 jlind23 added Team:Service-Integrations Label for the Service Integrations team and removed Team:Integrations Label for the Integrations team Team:Services (Deprecated) Label for the former Integrations-Services team labels Mar 31, 2022
@botelastic
Copy link

botelastic bot commented Mar 31, 2023

Hi!
We just realized that we haven't looked into this issue in a while. We're sorry!

We're labeling this issue as Stale to make it hit our filters and make sure we get back to it as soon as possible. In the meantime, it'd be extremely helpful if you could take a look at it as well and confirm its relevance. A simple comment with a nice emoji will be enough :+1.
Thank you for your contribution!

@botelastic botelastic bot added the Stalled label Mar 31, 2023
@MeijerM1
Copy link

MeijerM1 commented Apr 1, 2023

👍

@botelastic botelastic bot removed the Stalled label Apr 1, 2023
@evilezh
Copy link

evilezh commented Oct 19, 2023

I just hit the same problem. As soon we stop consumer .. there are no metrics anymore coming in. I'm just wondering how this is not hitting thousdans of people.
If there are no metrics - you can't really detect anything.

@wim82
Copy link

wim82 commented Apr 16, 2024

Same here. I would like to monitor consumer group lag - but if a consumer goes down, i do not see any lag anymore.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
bug Metricbeat Metricbeat module Team:Service-Integrations Label for the Service Integrations team
Projects
None yet
Development

No branches or pull requests

6 participants