Uses of Class
org.apache.storm.kafka.DynamicPartitionConnections

Packages that use DynamicPartitionConnections

Package	Description
org.apache.storm.kafka

Uses of DynamicPartitionConnections in org.apache.storm.kafka

Constructors in org.apache.storm.kafka with parameters of type DynamicPartitionConnections

Constructor and Description
KafkaOffsetMetric(DynamicPartitionConnections connections)
PartitionManager(DynamicPartitionConnections connections, String topologyInstanceId, ZkState state, Map stormConf, SpoutConfig spoutConfig, Partition id)
PartitionManager(DynamicPartitionConnections connections, String topologyInstanceId, ZkState state, Map stormConf, SpoutConfig spoutConfig, Partition id, PartitionManager previousManager)
StaticCoordinator(DynamicPartitionConnections connections, Map stormConf, SpoutConfig config, ZkState state, int taskIndex, int totalTasks, int taskId, String topologyInstanceId)
ZkCoordinator(DynamicPartitionConnections connections, Map stormConf, SpoutConfig spoutConfig, ZkState state, int taskIndex, int totalTasks, int taskId, String topologyInstanceId)
ZkCoordinator(DynamicPartitionConnections connections, Map stormConf, SpoutConfig spoutConfig, ZkState state, int taskIndex, int totalTasks, int taskId, String topologyInstanceId, DynamicBrokersReader reader)