Major Description
The mirroring code has an API that restarts the consumer connector when a new topic watcher fires. This triggers a rebalancing operation in the consumer connector. But if this rebalancing operation fails, the mirroring code simply throws an exception and never recovers. Ideally, if the rebalancing operation fails due to n retries, we should shut down the mirror