Acknowledging Pubsub messages in Flink Runner

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

Acknowledging Pubsub messages in Flink Runner

Encho Mishinev
Hello,

I have a simple question - when does the Flink Runner for Apache Beam acknowledge Pubsub messages when using PubsubIO?

Thanks
Reply | Threaded
Open this post in threaded view
|

Re: Acknowledging Pubsub messages in Flink Runner

Dawid Wysakowicz-2
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



signature.asc (849 bytes) Download Attachment