I have a consumer group with 15 consumers in it. When I start the process, around 200 records are processed by these 15 consumers in one minute, but later on as the number of incoming records goes down, I believe consumers start losing connection after being idle for 540000ms .
I want to see how many consumers are still active in a particular consumer group using kafka-python, so that I can add consumers to keep the processing going on. The same can be done using --member command in shell but I'm interested in doing it in kafka-python.
