storm-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From 이승진 <>
Subject is there a way for kafka spout to read from written zookeeper offset
Date Mon, 01 Dec 2014 09:48:27 GMT
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.
View raw message