We just want to clean-up old configuration from ZK. We can check from the offset API so we can delete based on offset .. is that right ? there is no date last associated with Consumer Group ? Is that right in ZK configuration ?
Thanks, Bhavesh On Thu, Oct 9, 2014 at 9:23 PM, Gwen Shapira <gshap...@cloudera.com> wrote: > The problem with Kafka is that we never know when a consumer is > "truly" inactive. > > But - if you decide to define inactive as consumer who's last offset > is lower than anything available on the log (or perhaps lagging by > over X messages?), its fairly easy to write a script to detect and > clean them directly on ZK. > > BTW. Why do you need to clean them? What issue do you see with just > letting them hang around? > > Gwen > > On Thu, Oct 9, 2014 at 9:18 PM, Bhavesh Mistry > <mistry.p.bhav...@gmail.com> wrote: > > Hi Kafka, > > > > We have lots of lingering console consumer group people have created for > > testing or debugging purpose for one time use via > > bin/kafka-console-consumer.sh. Is there auto purging that clean script > > that Kafka provide ? Is three any API to find out inactive Consumer > group > > and delete consumer group configuration. > > > > Thanks, > > > > Bhavesh >
