Currently, there is no callback on rebalance failure. The consumer will retry failed rebalances. If all retries fail, we just log the error.
Thanks, Jun On Wed, Mar 26, 2014 at 5:01 PM, Tom Amon <ta46...@gmail.com> wrote: > The pattern for creating and operating consumers that we use is to create > the consumer connector, create the streams and then consume each stream by > waiting on the iterator. > > If a rebalance occurs and fails, how is the error raised to the consumer? > Will I get an exception while waiting on the iterator? Is it swallowed and > the consumer is dead? > > Thanks. >
