org.apache.storm.kafka.trident

Class ZkBrokerReader

java.lang.Object

org.apache.storm.kafka.trident.ZkBrokerReader

All Implemented Interfaces:

IBrokerReader

public class ZkBrokerReader
extends java.lang.Object
implements IBrokerReader

Constructor Summary

Constructors

Constructor and Description
ZkBrokerReader(java.util.Map<java.lang.String,java.lang.Object> conf, java.lang.String topic, ZkHosts hosts)

Method Summary

Modifier and Type	Method and Description
void	close()
java.util.List<GlobalPartitionInformation>	getAllBrokers()
GlobalPartitionInformation	getBrokerForTopic(java.lang.String topic)

Methods inherited from class java.lang.Object

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

Constructor Detail

ZkBrokerReader

public ZkBrokerReader(java.util.Map<java.lang.String,java.lang.Object> conf,
                      java.lang.String topic,
                      ZkHosts hosts)

Method Detail

getBrokerForTopic

public GlobalPartitionInformation getBrokerForTopic(java.lang.String topic)

Specified by:

getBrokerForTopic in interface IBrokerReader

getAllBrokers

public java.util.List<GlobalPartitionInformation> getAllBrokers()

Specified by:

getAllBrokers in interface IBrokerReader

close

public void close()

Specified by:

close in interface IBrokerReader