Yes, afaik, checkpoints are supported and used only for UnboundedRead transforms.
> On 27 Aug 2020, at 19:18, Eleanore Jin <[email protected]> wrote: > > Hi all, > > Just would like to confirm, KafkaWriter > <https://github.com/apache/beam/blob/master/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaWriter.java> > has no state, so that means, when enabled checkpoint, no state will be > checkpointed from KafkaWriter? > > Thanks a lot! > Eleanore
