kafka-Cluster-deprecated.adoc

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