This for the new consumer? or old high-level consumer? For the old high-level consumer, rebalance happens on the consumer side for the following events:
* Opening new streams * ZK Session expiration * When partition information changes or consumer information changes I don't think there is a place with in the broker that broadcasts when a rebalance happens. There are listeners in the Consumer you can set to get that information, but as you pointed out in your question, this happens on the consumer side. I guess you could set watches on the following paths and expect a rebalance when those watches get triggered, but you'd miss out on ZK session expirations etc. * a ZK watch for /consumers/<your_group_id>/ids * a ZK data watch for /brokers/topics/<topic_name> On Tue, Mar 1, 2016 at 6:37 AM, craig w <codecr...@gmail.com> wrote: > Is there some way to monitor when a rebalance occurs other than at the > consumer level? > -- *Christian Posta* twitter: @christianposta http://www.christianposta.com/blog http://fabric8.io
