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 does the Flink Runner for Apache Beam
> acknowledge Pubsub messages when using PubsubIO?
>
> Thanks