Hi Jae, Do you want to reset the offset to the latest one when you *start *the job or when the just is *running*?
If it's the former one, you can use systems.system-name.samza.offset.default=upcoming systems.system-name.streams.stream-name.samza.reset.offset=true What is the reason that you do not want to use systems.system-name.streams.stream-name.samza.reset.offset ? Thanks, Fang, Yan yanfang...@gmail.com On Tue, Jul 14, 2015 at 12:49 AM, Bae, Jae Hyeon <metac...@gmail.com> wrote: > Hi > > I want to reset the offset for the job to the latest one, which means I > want to ignore them without using > systems.system-name.streams.stream-name.samza.reset.offset option. > > If I use checkpoint tool and reset the offset as -1 or Long.MAX_VALUE, in > my theory, kafka consumer will throw an exception and it will reset them as > the latest one, am I right? Otherwise, please let me know how to reset > offsets to the latest one. > > Thank you > Best, Jae >
