Cluster (deprecated)

Important

It seems that Cluster class is created using ZkUtils.getCluster that is used exclusively when ZKRebalancerListener does syncedRebalance (that in turn happens for the currently-deprecated ZookeeperConsumerConnector).

In other words, Cluster class and the page are soon to be removed.

kafka.cluster.Cluster private class represents a set of active brokers in a Kafka cluster.

Note
 There is also org.apache.kafka.common.Cluster.

topics Method

Caution
 FIXME

availablePartitionsForTopic Method

Caution
 FIXME

results matching ""

    No results matching ""