Hi,

We are writing a spout that needs to store its progress and unlike kafka,
the datastore here has no concept of storing offsets.

I looked at IStatefulBolt but that seems to be usable only for Bolts.
Any idea if an IStatefulSpout is planned for the recent future?
Thinking aloud, IStatefulSpout seems like would be a much more common
requirement than IStatefulBolt because its usually the spouts that keep
track of their progress while the bolts are just stateless (most of the
time) and idempotent (most of the time).

Also, is there a guide to use zookeeper for such use-cases?
I see some classes like org.apache.storm.zookeeper.Zookeeper and
org.apache.storm.utils.Utils which have some zookeeper related methods.

Is it a good idea to use these classes for storing some offsets in
zookeeper (data is not too heavy size wise and frequency of storage is
configurable) or wait for IStatefulSpout (if any is planned) ?


Thanks
SG

Reply via email to