KafkaSpout will read last committed offset from zookeeper. If there is no offset in the zookeeper than only it will use configured startOffsetTime. Can you check in your worker logs after restarting your topology for this message "No partition information found, using configuration to determine offset" -Harsha
On Mon, Dec 1, 2014, at 01:48 AM, 이승진 wrote: > 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 >
