Re: Acknowledging Pubsub messages in Flink Runner

2018-09-10 Thread Dawid Wysakowicz
Hi Encho, Flink does not provide Pubsub connector. I believe you are using Beam's coder for PubsubIO. If this is correct, I guess you might want to ask this question on Beam's mailing list. Regards, Dawid On 10/09/18 17:24, Encho Mishinev wrote: > Hello, > > I have a simple question - when doe

Acknowledging Pubsub messages in Flink Runner

2018-09-10 Thread Encho Mishinev
Hello, I have a simple question - when does the Flink Runner for Apache Beam acknowledge Pubsub messages when using PubsubIO? Thanks