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

Reply via email to