I am sure you have checked this but in case it is a new deployment, somewhere a 
bolt has to ack the tuple in order for it not to be sent again. Any tuples that 
don't get ack'd will get replayed. 


> On Nov 6, 2015, at 3:38 AM, Birendra Kumar Singh <[email protected]> wrote:
> 
> Hi
> 
> I am using Kafka with Storm as described here - 
> https://github.com/apache/storm/tree/master/external/storm-kafka
> However, If I kill my topology and start it again, it restarts the KafkaSpout 
> from offset 0. Ideally, it should restart from where it left off.
> My nimbus and supervisors are up and running all the time.
> 
> I am using the default zookeeper provided by kafka. 
> 
> storm version - 0.95
> kafka - 2.9.1

Reply via email to