CommitOffsetsInFinalize() и галочки в Apache Beam

Я работаю над приложением Beam, которое использует KafkaIO в качестве входных данных.

KafkaIO.<Long, GenericRecord>read()
            .withBootstrapServers("bootstrapServers")
            .withTopic("topicName")
            .withConsumerConfigUpdates(confs)
            .withKeyDeserializer(LongDeserializer.class)
            .withValueDeserializer((Deserializer.class)
            .commitOffsetsInFinalize()
            .withoutMetadata();

Я пытаюсь понять, как именно работает commitOffsetsInFinalize().

Как можно завершить потоковое задание? Последним шагом в конвейере является настраиваемый DoFn, который записывает сообщения в DynamoDb. Есть ли способ вручную вызвать там какой-нибудь метод finalize(), чтобы смещения фиксировались после каждого успешного выполнения DoFn?

Также мне трудно понять, какая связь между контрольными точками и финализацией? Если в конвейере не включена контрольная точка, смогу ли я доработать и заставить работать commitOffsetsInFinalize()?

p.s. То, как сейчас работает конвейер, даже с commitOffsetsInFinalize() каждым прочитанным сообщением, независимо от того, есть ли сбой в нисходящем направлении, фиксируется, что приводит к потере данных.

Спасибо!