storm.kafka.trident
Interface IBrokerReader

All Known Implementing Classes:
StaticBrokerReader, ZkBrokerReader

public interface IBrokerReader


Method Summary
 void close()
           
 GlobalPartitionInformation getCurrentBrokers()
           
 

Method Detail

getCurrentBrokers

GlobalPartitionInformation getCurrentBrokers()

close

void close()


Copyright © 2016 The Apache Software Foundation. All Rights Reserved.