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()
java.util.List<GlobalPartitionInformation>	getAllBrokers()
GlobalPartitionInformation	getBrokerForTopic(java.lang.String topic)

Method Detail

getBrokerForTopic

GlobalPartitionInformation getBrokerForTopic(java.lang.String topic)

getAllBrokers

java.util.List<GlobalPartitionInformation> getAllBrokers()

close

void close()