org.apache.storm.kafka.trident

Class ZkBrokerReader

java.lang.Object

org.apache.storm.kafka.trident.ZkBrokerReader

All Implemented Interfaces:

IBrokerReader

public class ZkBrokerReader
extends Object
implements IBrokerReader

Constructor Summary

Constructors

Constructor and Description
ZkBrokerReader(Map conf, String topic, ZkHosts hosts)

Method Summary

Modifier and Type	Method and Description
void	close()
List<GlobalPartitionInformation>	getAllBrokers()
GlobalPartitionInformation	getBrokerForTopic(String topic)

Methods inherited from class java.lang.Object

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

Constructor Detail

ZkBrokerReader

public ZkBrokerReader(Map conf,
                      String topic,
                      ZkHosts hosts)

Method Detail

getBrokerForTopic

public GlobalPartitionInformation getBrokerForTopic(String topic)

Specified by:

getBrokerForTopic in interface IBrokerReader

getAllBrokers

public List<GlobalPartitionInformation> getAllBrokers()

Specified by:

getAllBrokers in interface IBrokerReader

close

public void close()

Specified by:

close in interface IBrokerReader