org.apache.storm.kafka.trident

Interface IBrokerReader

All Known Implementing Classes:

StaticBrokerReader, ZkBrokerReader

public interface IBrokerReader

Method Summary

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

Method Detail

getBrokerForTopic

GlobalPartitionInformation getBrokerForTopic(String topic)

getAllBrokers

List<GlobalPartitionInformation> getAllBrokers()

close

void close()