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

results matching ""

    No results matching ""