Package org.apache.kafka.server.quota

Class ZkClientQuotaClusterDescriber

java.lang.Object

org.apache.kafka.server.quota.ZkClientQuotaClusterDescriber

All Implemented Interfaces:

ClientQuotaClusterDescriber

public class ZkClientQuotaClusterDescriber
extends Object
implements ClientQuotaClusterDescriber

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ZkClientQuotaClusterDescriber.PartitionIterator

Nested classes/interfaces inherited from interface org.apache.kafka.server.quota.ClientQuotaClusterDescriber

ClientQuotaClusterDescriber.Partition

Constructor Summary

Constructors

Constructor	Description
ZkClientQuotaClusterDescriber(Cluster cluster)

Method Summary

Modifier and Type	Method	Description
Cluster	cluster()
Iterator<ClientQuotaClusterDescriber.Partition>	partitionsForTopic(String topicName)	For the given topic, return the leader of each partition.
Iterator<String>	topicNames()	Get an iterator through all the topic names in the cluster.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ZkClientQuotaClusterDescriber

public ZkClientQuotaClusterDescriber(Cluster cluster)

Method Details

topicNames

public Iterator<String> topicNames()

Description copied from interface: ClientQuotaClusterDescriber

Get an iterator through all the topic names in the cluster.

Specified by:

topicNames in interface ClientQuotaClusterDescriber

partitionsForTopic

public Iterator<ClientQuotaClusterDescriber.Partition> partitionsForTopic(String topicName)

Description copied from interface: ClientQuotaClusterDescriber

For the given topic, return the leader of each partition.

Specified by:

partitionsForTopic in interface ClientQuotaClusterDescriber

cluster

public Cluster cluster()