Parsely / pykafka

Apache Kafka client for Python; high-level & low-level consumer/producer, with great performance.
http://pykafka.readthedocs.org/
Apache License 2.0
1.12k stars 232 forks source link

check group or all groups LAG #1005

Open malfonso0 opened 4 years ago

malfonso0 commented 4 years ago

hi.. i would like to know if there is a way to get the lag, as in how many messages are still pending to read. per topic or for all topics

in my case im working in a application, hosted on aws.. and want to create consumers based on lag with a load balancers

i want to get something like what i got with sh bin/kafka-consumer-groups.sh --describe --bootstrap-server --all-groups | or --group name

PyKafka version: latest Kafka version: .9

thanks