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