storm-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Stig Rohde Døssing <s...@apache.org>
Subject Re: Storm spout offset forwarding
Date Tue, 29 Aug 2017 07:18:56 GMT
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.pradeep@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
>

Mime
View raw message