Modifiers | Name | Description |
---|---|---|
protected java.util.AbstractMap<KafkaConsumer, java.lang.Integer> |
consumerOffsets |
|
protected java.util.List<groovy.lang.Closure> |
onConsumerData |
|
protected java.util.AbstractSet<java.lang.String> |
watchedTopics |
Fields inherited from class | Fields |
---|---|
class AbstractTreeWatcher |
cache, client, logger, onInitComplete |
Constructor and description |
---|
protected AbstractConsumerTreeWatcher
(org.apache.curator.framework.CuratorFramework client, java.util.AbstractSet topics, java.util.AbstractMap offsets) |
Type | Name and description |
---|---|
void |
childEvent(org.apache.curator.framework.CuratorFramework client, org.apache.curator.framework.recipes.cache.TreeCacheEvent event) Primary TreeCache event processing callback |
java.lang.Boolean |
isNodeEvent(org.apache.curator.framework.recipes.cache.TreeCacheEvent event) Return true if the TreeCacheEvent received pertains to a node event that we're interested in |
java.lang.Boolean |
isOffsetSubtree(java.lang.String path) Determine whether a given path is of interest, i.e. path which contains offset data |
ConsumerOffset |
processChildData(org.apache.curator.framework.recipes.cache.ChildData data) Process the ChildData associated with an event |
void |
trackConsumerOffset(ConsumerOffset offset) Keep track of a ConsumerOffset in the consumersMap that was passed into this class on instantiation |
Methods inherited from class | Name |
---|---|
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() |
Primary TreeCache event processing callback
Return true if the TreeCacheEvent received pertains to a node event that we're interested in
Determine whether a given path is of interest, i.e. path which contains offset data
Process the ChildData associated with an event
Keep track of a ConsumerOffset in the consumersMap that was passed into this class on instantiation