You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@storm.apache.org by saiprasad mishra <sa...@gmail.com> on 2014/09/08 19:44:50 UTC

How to consume from last offset when topology restarts(STORM-KAFKA)

Any update or resolution for this issue in storm kafka spout

Regards
Sai

Re: How to consume from last offset when topology restarts(STORM-KAFKA)

Posted by Curtis Allen <cu...@gmail.com>.

Have you tried the adding the following to your spout config?


SpoutConfig spoutConf = new SpoutConfig(...)
spoutConf.startOffsetTime = kafka.api.OffsetRequest.LatestTime();


I haven't tried it but looks like that should work.



On Mon, Sep 8, 2014 at 11:44 AM, saiprasad mishra <saiprasadmishra@gmail.com
> wrote:

> Any update or resolution for this issue in storm kafka spout
>
> Regards
> Sai
>