pykafka
pykafka copied to clipboard
check group or all groups LAG
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