Hi all,
 
Kafkaspout periodically write each partition offset to zookeeper.
 
and spoutConfig.startOffsetTime=-2 means from the beginning, -1 from the latest 
offset.
 
Is there a option to read from last committed consumer offset?
 
When I restart topology due to bugfix or whatsoever, some of the messages are 
not processed by storm because I set it to -1.
 
Sincerely
 

Reply via email to