Hi Vishal, You can probably try using similar offset configuration as a service consumer. Maybe this will be useful to look at [1]
Thanks, Rong [1] https://ci.apache.org/projects/flink/flink-docs-stable/dev/connectors/kafka.html#kafka-consumers-start-position-configuration On Wed, Nov 21, 2018 at 1:32 PM Jamie Grier <jgr...@lyft.com> wrote: > Hi Vishal, > > No, there is no way to do this currently. > > > On Wed, Nov 21, 2018 at 10:22 AM Vishal Santoshi < > vishal.santo...@gmail.com> wrote: > >> Any one ? >> >> On Tue, Nov 20, 2018 at 12:48 PM Vishal Santoshi < >> vishal.santo...@gmail.com> wrote: >> >>> Is it possible to have checkpointing but reset the kafka offsets to >>> latest on restart on failure ? >>> >>
