org.apache.storm.kafka

Class DynamicBrokersReader

java.lang.Object

org.apache.storm.kafka.DynamicBrokersReader

public class DynamicBrokersReader
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
DynamicBrokersReader(java.util.Map<java.lang.String,java.lang.Object> conf, java.lang.String zkStr, java.lang.String zkPath, java.lang.String topic)

Method Summary

Modifier and Type	Method and Description
java.lang.String	brokerPath()
void	close()
java.util.List<GlobalPartitionInformation>	getBrokerInfo() Get all partitions with their current leaders
java.lang.String	partitionPath(java.lang.String topic)
java.lang.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(java.util.Map<java.lang.String,java.lang.Object> conf,
                            java.lang.String zkStr,
                            java.lang.String zkPath,
                            java.lang.String topic)

Method Detail

getBrokerInfo

public java.util.List<GlobalPartitionInformation> getBrokerInfo()
                                                         throws java.net.SocketTimeoutException

Get all partitions with their current leaders

Throws:

java.net.SocketTimeoutException

topicsPath

public java.lang.String topicsPath()

partitionPath

public java.lang.String partitionPath(java.lang.String topic)

brokerPath

public java.lang.String brokerPath()

close

public void close()