Uses of Class
org.apache.storm.kafka.Broker

Packages that use Broker

Package	Description
org.apache.storm.kafka
org.apache.storm.kafka.trident

Uses of Broker in org.apache.storm.kafka

Fields in org.apache.storm.kafka declared as Broker

Modifier and Type	Field and Description
Broker	Partition.host

Methods in org.apache.storm.kafka that return Broker

Modifier and Type	Method and Description
static Broker	Broker.fromString(String host)

Methods in org.apache.storm.kafka with parameters of type Broker

Modifier and Type	Method and Description
int	Broker.compareTo(Broker o)
kafka.javaapi.consumer.SimpleConsumer	DynamicPartitionConnections.register(Broker host, String topic, int partition)
void	DynamicPartitionConnections.unregister(Broker port, String topic, int partition)

Constructors in org.apache.storm.kafka with parameters of type Broker

Constructor and Description
Partition(Broker host, String topic, int partition)
Partition(Broker host, String topic, int partition, Boolean bUseTopicNameForPartitionPathId)

Uses of Broker in org.apache.storm.kafka.trident

Methods in org.apache.storm.kafka.trident that return Broker

Modifier and Type	Method and Description
Broker	GlobalPartitionInformation.getBrokerFor(Integer partitionId)

Methods in org.apache.storm.kafka.trident with parameters of type Broker

Modifier and Type	Method and Description
void	GlobalPartitionInformation.addPartition(int partitionId, Broker broker)