org.apache.storm.kafka

Class DynamicPartitionConnections

java.lang.Object

org.apache.storm.kafka.DynamicPartitionConnections

public class DynamicPartitionConnections
extends Object

Constructor Summary

Constructors

Constructor and Description
DynamicPartitionConnections(KafkaConfig config, IBrokerReader brokerReader)

Method Summary

Modifier and Type	Method and Description
void	clear()
kafka.javaapi.consumer.SimpleConsumer	getConnection(Partition partition)
kafka.javaapi.consumer.SimpleConsumer	register(Broker host, String topic, int partition)
kafka.javaapi.consumer.SimpleConsumer	register(Partition partition)
void	unregister(Broker port, String topic, int partition)
void	unregister(Partition partition)

Methods inherited from class java.lang.Object

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

Constructor Detail

DynamicPartitionConnections

public DynamicPartitionConnections(KafkaConfig config,
                                   IBrokerReader brokerReader)

Method Detail

register

public kafka.javaapi.consumer.SimpleConsumer register(Partition partition)

register

public kafka.javaapi.consumer.SimpleConsumer register(Broker host,
                                                      String topic,
                                                      int partition)

getConnection

public kafka.javaapi.consumer.SimpleConsumer getConnection(Partition partition)

unregister

public void unregister(Broker port,
                       String topic,
                       int partition)

unregister

public void unregister(Partition partition)

clear

public void clear()