storm.kafka
Class DynamicBrokersReader

java.lang.Object
  extended by storm.kafka.DynamicBrokersReader

public class DynamicBrokersReader
extends Object


Field Summary
static org.slf4j.Logger LOG
           
 
Constructor Summary
DynamicBrokersReader(Map conf, String zkStr, String zkPath, String topic)
           
 
Method Summary
 String brokerPath()
           
 void close()
           
 GlobalPartitionInformation getBrokerInfo()
          Get all partitions with their current leaders
 String partitionPath()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

LOG

public static final org.slf4j.Logger LOG
Constructor Detail

DynamicBrokersReader

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

getBrokerInfo

public GlobalPartitionInformation getBrokerInfo()
                                         throws SocketTimeoutException
Get all partitions with their current leaders

Throws:
SocketTimeoutException

partitionPath

public String partitionPath()

brokerPath

public String brokerPath()

close

public void close()


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