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