Yan,
Thanks. This really helps.

- Shekar

On Fri, Jan 16, 2015 at 11:52 AM, Yan Fang <[email protected]> wrote:

> Hi Shekar,
>
> Assuming you are using 0.8, there are configurations that you can set to
> read messages from oldest.
>
> systems.system-name.streams.stream-name.samza.reset.offset = true
> systems.system-name.streams.stream-name.samza.offset.default = oldest
>
> See
>
> http://samza.incubator.apache.org/learn/documentation/0.8/jobs/configuration-table.html
>
> Hope this helps.
>
> Thanks,
>
> Fang, Yan
> [email protected]
> +1 (206) 849-4108
>
> On Fri, Jan 16, 2015 at 11:02 AM, Shekar Tippur <[email protected]> wrote:
>
> > Hello,
> >
> > I was wondering what would be the recommended way to point Samza to
> consume
> > older messages?
> >
> > I have made some code changes that I want to apply to all the messages
> that
> > have been read so far.
> >
> > - Shekar
> >
>

Reply via email to