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 >
