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 <[email protected] > wrote: > Any update or resolution for this issue in storm kafka spout > > Regards > Sai >
