Is there any guidance for checkpointing in 2.0?

Are you asking this in comparison to 1.0? I think checkpointing might have a different meaning so is there something specific you are trying to do?

in my head I mean where are we upto in a stream or what was the last time this ran so I can add a where clause to the query

Ah I understand. In 1.0 we had a KVStore but it’s not part of the 2.0 GA so you’d need to persist that watermark somewhere else for now

ok cheers - yeah a built-in 'persistent' redis would be nice