StandardTreeWatcher processes Zookeeper paths for standard high-level Kafka consumers
Fields inherited from class | Fields |
---|---|
class AbstractConsumerTreeWatcher |
consumerOffsets, onConsumerData, watchedTopics |
class AbstractTreeWatcher |
cache, client, logger, onInitComplete |
Type | Name and description |
---|---|
java.lang.Boolean |
isOffsetSubtree(java.lang.String path) |
ConsumerOffset |
processChildData(org.apache.curator.framework.recipes.cache.ChildData data) Extract the necessary information from a standard (i.e. high-level Kafka consumer) tree of offsets |
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 necessary information from a standard (i.e. high-level Kafka consumer) tree of offsets