Houve umpergunta sobre este tópico, a resposta dizia "A confirmação será feita quando a mensagem durar persistir em algum lugar no pipeline do Dataflow".

Conceitualmente, isso faz sentido, mas não tenho certeza de como o Dataflow é capaz de rastrear uma mensagem depois de ter sido desserializada e transformada no pipeline antes que sua carga útil persista.

No nosso caso, a mensagem do PubSub contém um lote de itens. Depois que a mensagem é recebida e desserializada, dividimos o lote para processamento. Eventualmente, um item no lote pode ser descartado ou confirmado no armazenamento de dados, dependendo do carimbo de data / hora.

Como o reconhecimento funciona nessa situação?