org.apache.storm.kafka

Interface PartitionCoordinator

All Known Implementing Classes:

StaticCoordinator, ZkCoordinator

public interface PartitionCoordinator

Method Summary

Modifier and Type	Method and Description
PartitionManager	getManager(Partition partition)
java.util.List<PartitionManager>	getMyManagedPartitions()
void	refresh()

Method Detail

getMyManagedPartitions

java.util.List<PartitionManager> getMyManagedPartitions()

getManager

PartitionManager getManager(Partition partition)

refresh

void refresh()