Thanks Alex! On Mon, Aug 31, 2020 at 9:32 AM Alexey Romanenko <[email protected]> wrote:
> 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 > > >
