KafkaSpoutTreeWatcher process Zookeeper paths normally associated with Storm KafkaSpout based consumers
Fields inherited from class | Fields |
---|---|
class AbstractConsumerTreeWatcher |
consumerOffsets, onConsumerData, watchedTopics |
class AbstractTreeWatcher |
cache, client, logger, onInitComplete |
Constructor and description |
---|
KafkaSpoutTreeWatcher
(org.apache.curator.framework.CuratorFramework client, java.util.AbstractSet topics, java.util.AbstractMap offsets) |
Type | Name and description |
---|---|
java.lang.String |
consumerNameFromPath(java.lang.String path) Extract the given name for a KafkaSpout consumer based on the path in Zookeeper |
java.lang.Boolean |
isOffsetSubtree(java.lang.String path) We're expecting things to look like: /kafka_spout/topologyname/partition_0 |
ConsumerOffset |
processChildData(org.apache.curator.framework.recipes.cache.ChildData nodeData) |
java.lang.String |
zookeeperPath() |
Methods inherited from class | Name |
---|---|
class AbstractConsumerTreeWatcher |
childEvent, isNodeEvent, isOffsetSubtree, processChildData, trackConsumerOffset |
class AbstractTreeWatcher |
childEvent, close, start, zookeeperPath |
class java.lang.Object |
java.lang.Object#wait(long, int), java.lang.Object#wait(long), java.lang.Object#wait(), java.lang.Object#equals(java.lang.Object), java.lang.Object#toString(), java.lang.Object#hashCode(), java.lang.Object#getClass(), java.lang.Object#notify(), java.lang.Object#notifyAll() |
Extract the given name for a KafkaSpout consumer based on the path in Zookeeper
We're expecting things to look like: /kafka_spout/topologyname/partition_0