confluentinc / confluent-kafka-dotnet

Confluent's Apache Kafka .NET client
https://github.com/confluentinc/confluent-kafka-dotnet/wiki
Apache License 2.0
2.78k stars 847 forks source link

list consumer lag per topic-partition and consumer-group #1204

Open michael-elly opened 4 years ago

michael-elly commented 4 years ago

Description

Hi, Looking for how to list consumer gap using the .NET API I was finally able to do it for a given topic and a consumer group. I can derive the partitions from the topic and then per consumer group find the lag. I was not able to do it per consumer group name only (cannot find the associated topics with a given consumer group name). See my query on stackoverflow: https://stackoverflow.com/questions/60506580/how-can-i-list-the-kafka-consumer-lag-and-latest-offset-per-partition-and-consum

How to reproduce

Checklist

Please provide the following information:

dmtrrk commented 4 years ago

is there any chance to link topics with consumer groups using SDK?

wxlevel commented 3 years ago

did you find how to map topic to consumer groups to generate topic_partition list ?