ZKRebalancerListener ZKRebalancerListener is…FIXME syncedRebalance Method syncedRebalance(): Unit syncedRebalance…FIXME Note syncedRebalance is used when: ZKSessionExpireListener does handleNewSession That happens exclusively in (deprecated) ZookeeperConsumerConnector ZKRebalancerListener is created (and creates watcherExecutorThread) That happens exclusively in (deprecated) ZookeeperConsumerConnector (deprecated) ZookeeperConsumerConnector does reinitializeConsumer