Hi Stig, Please find the details Storm version 1.1.0. Using latest kafka spout which stores offsets inside kafka _consumer_offsets topic .
storm-kafka-client dependency used : version 1.1.1 Kafka version is 0.10.1.0 Thanks Pradeep On Tue, Aug 29, 2017 at 12:18 AM, Stig Rohde Døssing <s...@apache.org> wrote: > Hi Pradeep, > > I think it will be easier to give advice if we know the following: > > Which Storm version are you on? > Which spout are you using? Is it storm-kafka or storm-kafka-client, and is > it Trident or regular Storm? > Which Kafka version are you on? > > 2017-08-29 7:33 GMT+02:00 pradeep s <sreekumar.prad...@gmail.com>: > >> Hi, >> I want reset the storm consumer to latest offset for avoiding few >> messages . >> >> I followed below steps >> >> >> 1. Stop storm consumer >> 2. Reset the retention period for the topic to 1 ms >> 3. Wait for few fins >> 4. Reset the retention period back to original value of 5 days >> 5. Start storm consumer >> >> Is this approach ok in moving storm spout to latest offset.. >> I am seeing that Kafka manager still shows a lag for the topic >> >> >> thanks >> pradeep >> > >
