org.apache.storm.kafka

Class DynamicBrokersReader

java.lang.Object

org.apache.storm.kafka.DynamicBrokersReader

public class DynamicBrokersReader
extends Object

Constructor Summary

Constructors

Constructor and Description
DynamicBrokersReader(Map conf, String zkStr, String zkPath, String topic)

Method Summary

Modifier and Type	Method and Description
String	brokerPath()
void	close()
List<GlobalPartitionInformation>	getBrokerInfo() Get all partitions with their current leaders
String	partitionPath(String topic)
String	topicsPath()

Methods inherited from class java.lang.Object

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

Constructor Detail

DynamicBrokersReader

public DynamicBrokersReader(Map conf,
                            String zkStr,
                            String zkPath,
                            String topic)

Method Detail

getBrokerInfo

public List<GlobalPartitionInformation> getBrokerInfo()
                                               throws SocketTimeoutException

Get all partitions with their current leaders

Throws:

SocketTimeoutException

topicsPath

public String topicsPath()

partitionPath

public String partitionPath(String topic)

brokerPath

public String brokerPath()

close

public void close()