storm-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From 이승진 <sweetest...@navercorp.com>
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.
 
Sincerely
 
Mime
View raw message