The example of consumer api is here: https://cwiki.apache.org/confluence/display/KAFKA/Consumer+Group+Example
I read the source code of the consumer [kafka.consumer.ZookeeperConsumerConnector] , I found the rebalance was completed in consumer. I want to know, when a consumer A watched the /consumer/[group_id]/ids/ path and found a new consumer B was joined, then A and B will rebalance, before the rebalance was finished, the consumer C was joined too and rebalace itself ..... I mean that when there were too many consumers was setup, every consumer will rebalance again and again, it's inefficiency. I want to try to realize a centralized rebalance manager, but it can not solve the problem that rebalace too many when more consumers joined one by one. Any one can help me ?
