DynamicPartitionConnections (Storm 0.10.2 API)

public class DynamicPartitionConnections
extends Object

Fields
Modifier and Type	Field and Description
`static org.slf4j.Logger`	`LOG`

Constructors
Constructor and Description
`DynamicPartitionConnections(KafkaConfig config, IBrokerReader brokerReader)`

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`clear()`
`kafka.javaapi.consumer.SimpleConsumer`	`getConnection(Partition partition)`
`kafka.javaapi.consumer.SimpleConsumer`	`register(Broker host, int partition)`
`kafka.javaapi.consumer.SimpleConsumer`	`register(Partition partition)`
`void`	`unregister(Broker port, int partition)`
`void`	`unregister(Partition partition)`

public static final org.slf4j.Logger LOG

public DynamicPartitionConnections(KafkaConfig config,
                                   IBrokerReader brokerReader)

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

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

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

public void unregister(Broker port,
                       int partition)

public void unregister(Partition partition)

Class DynamicPartitionConnections